openstack/aodh
Code Issues Proposed changes

Merge "transform samples only when transformers exist"

Browse Source
This commit is contained in:
Jenkins 2014-11-24 09:39:07 +00:00 committed by Gerrit Code Review
commit f09dd12c0e
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
ceilometer/pipeline.py
View File

@ -288,15 +288,18 @@ class Sink(object):
"""
transformed_samples = []
for sample in samples:
LOG.debug(_(
"Pipeline %(pipeline)s: Transform sample "
"%(smp)s from %(trans)s transformer") % ({'pipeline': self,
'smp': sample,
'trans': start}))
sample = self._transform_sample(start, ctxt, sample)
if sample:
transformed_samples.append(sample)
if not self.transformers:
transformed_samples = samples
else:
for sample in samples:
LOG.debug(_(
"Pipeline %(pipeline)s: Transform sample "
"%(smp)s from %(trans)s transformer") % ({'pipeline': self,
'smp': sample,
'trans': start}))
sample = self._transform_sample(start, ctxt, sample)
if sample:
transformed_samples.append(sample)
if transformed_samples:
for p in self.publishers: