openstack
/
mistral
Code Issues Proposed changes

Correction of comments for the #539039 review 

Change-Id: Id76c20d2da20c362ca94727e5c5dea2e19ed6b6d
Signed-off-by: Vitalii Solodilov <mcdkr@yandex.ru>
This commit is contained in:
Vitalii Solodilov 2018-02-12 04:09:12 +04:00
parent 82d5d10f89
commit e8d6c382c5
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
mistral/engine/action_queue.py
View File

@ -57,8 +57,7 @@ def _process_queue(queue):
for operation, args in queue:
if operation == _RUN_ACTION:
action_ex, action_def, target, execution_context, \
timeout = args
action_ex, action_def, target, execution_context, timeout = args
executor.run_action(
action_ex.id,

3
mistral/engine/policies.py
View File

@ -28,8 +28,9 @@ import six
_CONTINUE_TASK_PATH = 'mistral.engine.policies._continue_task'
_COMPLETE_TASK_PATH = 'mistral.engine.policies._complete_task'
_FAIL_IF_INCOMPLETE_TASK_PATH = \
_FAIL_IF_INCOMPLETE_TASK_PATH = (
'mistral.engine.policies._fail_task_if_incomplete'
)
def _log_task_delay(task_ex, delay_sec):

4
mistral/tests/unit/engine/test_policies.py
View File

@ -1437,7 +1437,7 @@ class PoliciesTest(base.EngineTestCase):
self.await_workflow_error(wf_ex.id)
def test_action_timeout(self):
wb = """---
wf_text = """---
version: '2.0'
wf1:
tasks:
@ -1446,7 +1446,7 @@ class PoliciesTest(base.EngineTestCase):
timeout: 2
"""
wf_service.create_workflows(wb)
wf_service.create_workflows(wf_text)
wf_ex = self.engine.start_workflow('wf1')
with db_api.transaction():