diff options
Diffstat (limited to 'taskflow/engines/worker_based/worker.py')
| -rw-r--r-- | taskflow/engines/worker_based/worker.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/taskflow/engines/worker_based/worker.py b/taskflow/engines/worker_based/worker.py index 18627e2..f75b7a8 100644 --- a/taskflow/engines/worker_based/worker.py +++ b/taskflow/engines/worker_based/worker.py @@ -21,12 +21,13 @@ import string import sys from concurrent import futures +from oslo.utils import reflection from taskflow.engines.worker_based import endpoint from taskflow.engines.worker_based import server from taskflow import logging from taskflow import task as t_task -from taskflow.utils import reflection +from taskflow.utils import misc from taskflow.utils import threading_utils as tu from taskflow import version @@ -103,7 +104,7 @@ class Worker(object): @staticmethod def _derive_endpoints(tasks): """Derive endpoints from list of strings, classes or packages.""" - derived_tasks = reflection.find_subclasses(tasks, t_task.BaseTask) + derived_tasks = misc.find_subclasses(tasks, t_task.BaseTask) return [endpoint.Endpoint(task) for task in derived_tasks] def _generate_banner(self): |