fix problem in renaming

This commit is contained in:
Romain Dorgueil
2016-12-25 14:25:51 +01:00
parent 7b34b43b08
commit b07019f789

View File

@ -137,7 +137,7 @@ class ComponentExecutionContext(WithStatistics):
self.stats['in'] += 1
return self.input.get(timeout=1)
def _call(self, bag_or_arg):
def _call(self, bag):
# todo add timer
if getattr(self.component, '_with_context', False):
return bag.apply(self.component, self)