openstack/deb-python-taskflow
Code Issues Proposed changes

Rename t_storage to atom_storage

Browse Source 
This name reflects better what the storage module is
actually being used for/does. The prior name was not
very informative and meaningful.

Part of blueprint plug-engine

Change-Id: I7015620f5536fc766cff3a877edd0e94d25db1ed
This commit is contained in:
Joshua Harlow
2014-05-19 22:25:25 -07:00
committed by Thomas Goirand
parent c1f37e5fa3
commit c05e50446a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -28,7 +28,7 @@ from taskflow import exceptions as exc
from taskflow.openstack.common import excutils
from taskflow import retry
from taskflow import states
from taskflow import storage as t_storage
from taskflow import storage as atom_storage
from taskflow.utils import lock_utils
from taskflow.utils import misc
@@ -231,12 +231,12 @@ class ActionEngine(base.EngineBase):
class SingleThreadedActionEngine(ActionEngine):
"""Engine that runs tasks in serial manner."""
_storage_factory = t_storage.SingleThreadedStorage
_storage_factory = atom_storage.SingleThreadedStorage
class MultiThreadedActionEngine(ActionEngine):
"""Engine that runs tasks in parallel manner."""
_storage_factory = t_storage.MultiThreadedStorage
_storage_factory = atom_storage.MultiThreadedStorage
def _task_executor_factory(self):
return executor.ParallelTaskExecutor(self._executor)