diff options
Diffstat (limited to 'taskflow/engines/worker_based/executor.py')
| -rw-r--r-- | taskflow/engines/worker_based/executor.py | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/taskflow/engines/worker_based/executor.py b/taskflow/engines/worker_based/executor.py index cd068e8..bdef7bf 100644 --- a/taskflow/engines/worker_based/executor.py +++ b/taskflow/engines/worker_based/executor.py @@ -27,7 +27,6 @@ from taskflow import exceptions as exc from taskflow import logging from taskflow import task as task_atom from taskflow.types import timing as tt -from taskflow.utils import async_utils from taskflow.utils import misc from taskflow.utils import reflection from taskflow.utils import threading_utils as tu @@ -248,10 +247,6 @@ class WorkerTaskExecutor(executor.TaskExecutor): progress_callback, result=result, failures=failures) - def wait_for_any(self, fs, timeout=None): - """Wait for futures returned by this executor to complete.""" - return async_utils.wait_for_any(fs, timeout) - def wait_for_workers(self, workers=1, timeout=None): """Waits for geq workers to notify they are ready to do work. |