diff options
author | Jenkins <jenkins@review.openstack.org> | 2015-12-16 10:25:22 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2015-12-16 10:25:22 +0000 |
commit | 5dd8b28f03ac28fbc959b4999baaba598ac18f70 (patch) | |
tree | 9708fdcb0fe752ed38c8df8a7bdf6f102c2470a2 /taskflow/conductors | |
parent | b54701e604acc267f1eff15d9b61451f0c1cc4e1 (diff) | |
parent | ff0cb5d5b0eca847c62a9ebab3dbf318fa1a0469 (diff) | |
download | taskflow-5dd8b28f03ac28fbc959b4999baaba598ac18f70.tar.gz |
Merge "Avoid recreating notify details for each dispatch iteration"
Diffstat (limited to 'taskflow/conductors')
-rw-r--r-- | taskflow/conductors/backends/impl_executor.py | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/taskflow/conductors/backends/impl_executor.py b/taskflow/conductors/backends/impl_executor.py index d61f3e0..509ce32 100644 --- a/taskflow/conductors/backends/impl_executor.py +++ b/taskflow/conductors/backends/impl_executor.py @@ -183,22 +183,19 @@ class ExecutorConductor(base.Conductor): stack.enter_context(listener) self._log.debug("Dispatching engine for job '%s'", job) consume = True + details = { + 'job': job, + 'engine': engine, + 'conductor': self, + } try: for stage_func, event_name in [(engine.compile, 'compilation'), (engine.prepare, 'preparation'), (engine.validate, 'validation'), (engine.run, 'running')]: - self._notifier.notify("%s_start" % event_name, { - 'job': job, - 'engine': engine, - 'conductor': self, - }) + self._notifier.notify("%s_start" % event_name, details) stage_func() - self._notifier.notify("%s_end" % event_name, { - 'job': job, - 'engine': engine, - 'conductor': self, - }) + self._notifier.notify("%s_end" % event_name, details) except excp.WrappedFailure as e: if all((f.check(*self.NO_CONSUME_EXCEPTIONS) for f in e)): consume = False |