openstack/mistral
Code Issues Proposed changes

Correction of comments for the #539039 review

Browse Source 
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: for operation, args in queue:
if operation == _RUN_ACTION: if operation == _RUN_ACTION:
action_ex, action_def, target, execution_context, \ action_ex, action_def, target, execution_context, timeout = args
timeout = args
executor.run_action( executor.run_action(
action_ex.id, action_ex.id,

3
mistral/engine/policies.py
View File

@ -28,8 +28,9 @@ import six
_CONTINUE_TASK_PATH = 'mistral.engine.policies._continue_task' _CONTINUE_TASK_PATH = 'mistral.engine.policies._continue_task'
_COMPLETE_TASK_PATH = 'mistral.engine.policies._complete_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' 'mistral.engine.policies._fail_task_if_incomplete'
)
def _log_task_delay(task_ex, delay_sec): 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) self.await_workflow_error(wf_ex.id)
def test_action_timeout(self): def test_action_timeout(self):
wb = """--- wf_text = """---
version: '2.0' version: '2.0'
wf1: wf1:
tasks: tasks:
@ -1446,7 +1446,7 @@ class PoliciesTest(base.EngineTestCase):
timeout: 2 timeout: 2
""" """
wf_service.create_workflows(wb) wf_service.create_workflows(wf_text)
wf_ex = self.engine.start_workflow('wf1') wf_ex = self.engine.start_workflow('wf1')
with db_api.transaction(): with db_api.transaction():