Fix config bug.
Fixes issue with the trigger manager loaded by the pipeline worker not getting the proper default value for distiller_trait_plugins.
This commit is contained in:
parent
db434c24c4
commit
5e2a29610e
@ -91,30 +91,23 @@ class PipelineManager(object):
|
|||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def config_description(cls):
|
def config_description(cls):
|
||||||
return dict(config_path=ConfigItem(help="Path(s) to find additional config files",
|
configs = TriggerManager.config_description()
|
||||||
multiple=True, default='.'),
|
configs.update(dict(
|
||||||
pipeline_handlers=ConfigItem(required=True,
|
pipeline_handlers=ConfigItem(required=True,
|
||||||
help="dictionary of pipeline handlers to load "
|
help="dictionary of pipeline handlers to load "
|
||||||
"Classes specified with simport syntax. "
|
"Classes specified with simport syntax. "
|
||||||
"simport docs for more info"),
|
"simport docs for more info"),
|
||||||
statistics_period=ConfigItem(help="Emit stats on event counts, etc every "
|
|
||||||
"this many seconds", default=10),
|
|
||||||
pipeline_worker_batch_size=ConfigItem(help="Number of streams for pipeline "
|
pipeline_worker_batch_size=ConfigItem(help="Number of streams for pipeline "
|
||||||
"worker(s) to load at a time", default=1000),
|
"worker(s) to load at a time", default=1000),
|
||||||
pipeline_worker_delay=ConfigItem(help="Number of seconds for pipeline worker to sleep "
|
pipeline_worker_delay=ConfigItem(help="Number of seconds for pipeline worker to sleep "
|
||||||
"when it finds no streams to process", default=10),
|
"when it finds no streams to process", default=10),
|
||||||
database=ConfigSection(help="Database connection info.",
|
|
||||||
config_description=DBInterface.config_description()),
|
|
||||||
trigger_definitions=ConfigItem(required=True,
|
|
||||||
help="Name of trigger definitions file "
|
|
||||||
"defining trigger conditions and what events to "
|
|
||||||
"process for each stream"),
|
|
||||||
pipeline_config=ConfigItem(required=True,
|
pipeline_config=ConfigItem(required=True,
|
||||||
help="Name of pipeline config file "
|
help="Name of pipeline config file "
|
||||||
"defining the handlers for each pipeline."),
|
"defining the handlers for each pipeline."),
|
||||||
purge_completed_streams=ConfigItem(help="Delete successfully proccessed "
|
purge_completed_streams=ConfigItem(help="Delete successfully proccessed "
|
||||||
"streams when finished?", default=True),
|
"streams when finished?", default=True),
|
||||||
)
|
))
|
||||||
|
return configs
|
||||||
|
|
||||||
def __init__(self, config, db=None, pipeline_handlers=None, pipeline_config=None, trigger_defs=None):
|
def __init__(self, config, db=None, pipeline_handlers=None, pipeline_config=None, trigger_defs=None):
|
||||||
logger.debug("PipelineManager: Using config: %s" % str(config))
|
logger.debug("PipelineManager: Using config: %s" % str(config))
|
||||||
|
Loading…
Reference in New Issue
Block a user