Merge "pipeline: fix format error in logging"
This commit is contained in:
@@ -150,8 +150,7 @@ class Pipeline(object):
|
|||||||
set(self.publishers).difference(
|
set(self.publishers).difference(
|
||||||
set(self.publisher_manager.names())), cfg)
|
set(self.publisher_manager.names())), cfg)
|
||||||
|
|
||||||
@staticmethod
|
def _setup_transformers(self, cfg, transformer_manager):
|
||||||
def _setup_transformers(cfg, transformer_manager):
|
|
||||||
transformer_cfg = cfg['transformers'] or []
|
transformer_cfg = cfg['transformers'] or []
|
||||||
transformers = []
|
transformers = []
|
||||||
for transformer in transformer_cfg:
|
for transformer in transformer_cfg:
|
||||||
@@ -165,13 +164,13 @@ class Pipeline(object):
|
|||||||
transformers.append(ext.plugin(**parameter))
|
transformers.append(ext.plugin(**parameter))
|
||||||
LOG.info("Pipeline %s: Setup transformer instance %s "
|
LOG.info("Pipeline %s: Setup transformer instance %s "
|
||||||
"with parameter %s",
|
"with parameter %s",
|
||||||
|
self,
|
||||||
transformer['name'],
|
transformer['name'],
|
||||||
parameter)
|
parameter)
|
||||||
|
|
||||||
return transformers
|
return transformers
|
||||||
|
|
||||||
@staticmethod
|
def _publish_counter_to_one_publisher(self, ext, ctxt, counter, source):
|
||||||
def _publish_counter_to_one_publisher(ext, ctxt, counter, source):
|
|
||||||
try:
|
try:
|
||||||
ext.obj.publish_counter(ctxt, counter, source)
|
ext.obj.publish_counter(ctxt, counter, source)
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
|
|||||||
Reference in New Issue
Block a user