openstack/deb-python-taskflow
Code Issues Proposed changes

Merge "Reduce visibility of task_action"

Browse Source
This commit is contained in:
Jenkins
2014-01-08 18:57:05 +00:00
committed by Gerrit Code Review
parent 5f0f10ce35 f1058af707
commit d617864898
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -62,9 +62,9 @@ class ActionEngine(base.EngineBase):
self.notifier = misc.TransitionNotifier() self.notifier = misc.TransitionNotifier()
self.task_notifier = misc.TransitionNotifier() self.task_notifier = misc.TransitionNotifier()
self._task_executor = self._task_executor_cls() self._task_executor = self._task_executor_cls()
self.task_action = self._task_action_cls(self.storage, self._task_action = self._task_action_cls(self.storage,
self._task_executor, self._task_executor,
self.task_notifier) self.task_notifier)
def _revert(self, current_failure=None): def _revert(self, current_failure=None):
self._change_state(states.REVERTING) self._change_state(states.REVERTING)
@@ -176,7 +176,7 @@ class ActionEngine(base.EngineBase):
self.storage) self.storage)
self._root = self._graph_action_cls(self._analyzer, self._root = self._graph_action_cls(self._analyzer,
self.storage, self.storage,
self.task_action) self._task_action)
for task in task_graph.nodes_iter(): for task in task_graph.nodes_iter():
task_version = misc.get_version_string(task) task_version = misc.get_version_string(task)
self.storage.ensure_task(task.name, task_version, task.save_as) self.storage.ensure_task(task.name, task_version, task.save_as)