openstack/deb-python-taskflow
Code Issues Proposed changes

Merge "Pass through run timeout in engine run()"

Browse Source
This commit is contained in:
Jenkins
2016-01-26 00:30:29 +00:00
committed by Gerrit Code Review
parent 615743c71a f5cd0632aa
commit 179eac734d
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
taskflow/engines/action_engine/engine.py
View File

@@ -216,12 +216,18 @@ class ActionEngine(base.Engine):
backend=self._backend, backend=self._backend,
scope_fetcher=_scope_fetcher) scope_fetcher=_scope_fetcher)
def run(self): def run(self, timeout=None):
"""Runs the engine (or die trying).
:param timeout: timeout to wait for any atoms to complete (this timeout
will be used during the waiting period that occurs when
unfinished atoms are being waited on).
"""
with fasteners.try_lock(self._lock) as was_locked: with fasteners.try_lock(self._lock) as was_locked:
if not was_locked: if not was_locked:
raise exc.ExecutionFailure("Engine currently locked, please" raise exc.ExecutionFailure("Engine currently locked, please"
" try again later") " try again later")
for _state in self.run_iter(): for _state in self.run_iter(timeout=timeout):
pass pass
def run_iter(self, timeout=None): def run_iter(self, timeout=None):