diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2014-12-15 15:47:58 -0800 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2014-12-15 15:52:39 -0800 |
| commit | 97b4e18cc2b4e6c0ae7228ff70ef75dc4a5a1df7 (patch) | |
| tree | 84fd5152dad6a4c480de4e435c10f9f3f3661e25 /taskflow/engines/worker_based/executor.py | |
| parent | 7dc11bae11e532cff5ac41c0ec942b1d4e76bc8b (diff) | |
| download | taskflow-97b4e18cc2b4e6c0ae7228ff70ef75dc4a5a1df7.tar.gz | |
Base task executor should provide 'wait_for_any'
Instead of having each task executor reproduce the same
code for 'wait_for_any' we can just have the base task
implementation provide the function that everyone is
replicating instead; making common code common and save
the headache caused by the same code being in multiple
places (which is bad for multiple reasons).
Change-Id: Icea4b7e3df605ab11b17c248d05acb3f9c02a1ca
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. |