diff options
Diffstat (limited to 'taskflow/engines/worker_based/engine.py')
| -rw-r--r-- | taskflow/engines/worker_based/engine.py | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/taskflow/engines/worker_based/engine.py b/taskflow/engines/worker_based/engine.py index aee39e8..31dcade 100644 --- a/taskflow/engines/worker_based/engine.py +++ b/taskflow/engines/worker_based/engine.py @@ -17,7 +17,6 @@ from taskflow.engines.action_engine import engine from taskflow.engines.worker_based import executor from taskflow.engines.worker_based import protocol as pr -from taskflow import storage as t_storage class WorkerBasedActionEngine(engine.ActionEngine): @@ -46,8 +45,6 @@ class WorkerBasedActionEngine(engine.ActionEngine): (see: :py:attr:`~.proxy.Proxy.DEFAULT_RETRY_OPTIONS`) """ - _storage_factory = t_storage.SingleThreadedStorage - def __init__(self, flow, flow_detail, backend, options): super(WorkerBasedActionEngine, self).__init__(flow, flow_detail, backend, options) |