summaryrefslogtreecommitdiff
path: root/taskflow/engines/action_engine/executor.py
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@gmail.com>2014-12-12 22:00:51 -0800
committerJoshua Harlow <harlowja@gmail.com>2014-12-12 22:05:03 -0800
commitf5060ff41ea3fd2f9282c00a5a63f110918568b0 (patch)
tree8988b7e9c25562966db5c317f8d97d4a6638637c /taskflow/engines/action_engine/executor.py
parentb4e4e214cb69a3f2b9d90c287dcc2dd521a7f425 (diff)
downloadtaskflow-f5060ff41ea3fd2f9282c00a5a63f110918568b0.tar.gz
Remove the base postfix from the internal task executor
There is no need to have a postfix of 'base' in the task executor as it is obvious by having a metaclass of abc.ABCMeta and the fact that it has no methods that the task executor base is a base class and should be used as such without a 'base' postfix to also signify the same information. Change-Id: I1f5cbcd29f1453d68e774f9f9f733eb873efc7cb
Diffstat (limited to 'taskflow/engines/action_engine/executor.py')
-rw-r--r--taskflow/engines/action_engine/executor.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/taskflow/engines/action_engine/executor.py b/taskflow/engines/action_engine/executor.py
index 9224adb..f91a615 100644
--- a/taskflow/engines/action_engine/executor.py
+++ b/taskflow/engines/action_engine/executor.py
@@ -61,7 +61,7 @@ def _revert_task(task, arguments, result, failures, progress_callback):
@six.add_metaclass(abc.ABCMeta)
-class TaskExecutorBase(object):
+class TaskExecutor(object):
"""Executes and reverts tasks.
This class takes task and its arguments and executes or reverts it.
@@ -91,8 +91,8 @@ class TaskExecutorBase(object):
pass
-class SerialTaskExecutor(TaskExecutorBase):
- """Execute task one after another."""
+class SerialTaskExecutor(TaskExecutor):
+ """Executes tasks one after another."""
def __init__(self):
self._executor = futures.SynchronousExecutor()
@@ -114,7 +114,7 @@ class SerialTaskExecutor(TaskExecutorBase):
return async_utils.wait_for_any(fs, timeout)
-class ParallelTaskExecutor(TaskExecutorBase):
+class ParallelTaskExecutor(TaskExecutor):
"""Executes tasks in parallel.
Submits tasks to an executor which should provide an interface similar