openstack/deb-mistral
Code Issues Proposed changes

Merge "Fixing task/workflow specs to do transformations with 'on-XXX' once"

Browse Source
This commit is contained in:
Jenkins 2014-09-19 01:58:15 +00:00 committed by Gerrit Code Review
commit 22953c168b
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
mistral/workbook/v2/tasks.py
View File

@ -60,6 +60,9 @@ class TaskSpec(base.BaseSpec):
task_policies.TaskPoliciesSpec
)
self._requires = data.get('requires', [])
self._on_complete = self._as_list_of_tuples('on-complete')
self._on_success = self._as_list_of_tuples('on-success')
self._on_error = self._as_list_of_tuples('on-error')
self._process_action_and_workflow()
@ -112,13 +115,13 @@ class TaskSpec(base.BaseSpec):
return self._requires
def get_on_complete(self):
return self._as_list_of_tuples('on-complete')
return self._on_complete
def get_on_success(self):
return self._as_list_of_tuples('on-success')
return self._on_success
def get_on_error(self):
return self._as_list_of_tuples('on-error')
return self._on_error
class TaskSpecList(base.BaseSpecList):

9
mistral/workbook/v2/workflows.py
View File

@ -49,6 +49,9 @@ class WorkflowSpec(base.BaseSpec):
self._output = data.get('output', {})
# TODO(rakhmerov): Build workflow policies specification.
self._policies = None
self._on_task_complete = self._as_list_of_tuples("on-task-complete")
self._on_task_success = self._as_list_of_tuples("on-task-success")
self._on_task_error = self._as_list_of_tuples("on-task-error")
self._tasks = self._spec_property('tasks', tasks.TaskSpecList)
@ -71,13 +74,13 @@ class WorkflowSpec(base.BaseSpec):
return self._policies
def get_on_task_complete(self):
return self._as_list_of_tuples("on-task-complete")
return self._on_task_complete
def get_on_task_success(self):
return self._as_list_of_tuples("on-task-success")
return self._on_task_success
def get_on_task_error(self):
return self._as_list_of_tuples("on-task-error")
return self._on_task_error
def get_tasks(self):
return self._tasks