diff options
| author | Greg Hill <greg.hill@rackspace.com> | 2016-01-13 13:47:03 -0600 |
|---|---|---|
| committer | Joshua Harlow <harlowja@gmail.com> | 2016-02-18 19:58:59 -0800 |
| commit | ec26bbffc6985792d4502ac9f4d4cb0960b16832 (patch) | |
| tree | 46c8bdd1f47bd93a678038b7bf288753e5c83a4a /taskflow/engines | |
| parent | 17e0f16ce9aa4ff8837416098975be17b3607dba (diff) | |
| download | taskflow-ec26bbffc6985792d4502ac9f4d4cb0960b16832.tar.gz | |
Refactor Atom/BaseTask/Task/Retry class hierarchy
* Moved common argument mapping logic to Atom
* Removed BaseTask
* Removed duplicated logic from subclasses
Change-Id: I275745adb80cecb0c35c1230eac76436bf3b0157
Diffstat (limited to 'taskflow/engines')
| -rw-r--r-- | taskflow/engines/action_engine/compiler.py | 2 | ||||
| -rw-r--r-- | taskflow/engines/worker_based/worker.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/taskflow/engines/action_engine/compiler.py b/taskflow/engines/action_engine/compiler.py index 9933fd0..ab0e443 100644 --- a/taskflow/engines/action_engine/compiler.py +++ b/taskflow/engines/action_engine/compiler.py @@ -326,7 +326,7 @@ class PatternCompiler(object): self._compilation = None self._matchers = [ (flow.Flow, FlowCompiler(self._compile)), - (task.BaseTask, TaskCompiler()), + (task.Task, TaskCompiler()), ] self._level = 0 diff --git a/taskflow/engines/worker_based/worker.py b/taskflow/engines/worker_based/worker.py index a462c7f..b4b820d 100644 --- a/taskflow/engines/worker_based/worker.py +++ b/taskflow/engines/worker_based/worker.py @@ -113,7 +113,7 @@ System details: @staticmethod def _derive_endpoints(tasks): """Derive endpoints from list of strings, classes or packages.""" - derived_tasks = misc.find_subclasses(tasks, t_task.BaseTask) + derived_tasks = misc.find_subclasses(tasks, t_task.Task) return [endpoint.Endpoint(task) for task in derived_tasks] def _generate_banner(self): |