Bump futurist and remove waiting code in taskflow

Change-Id: Ifc9780aa129a4a2804cead301a519895c2bfc0b5

1 files changed, 3 insertions, 3 deletions

diff --git a/taskflow/tests/unit/worker_based/test_pipeline.py b/taskflow/tests/unit/worker_based/test_pipeline.py
index a207576..5674015 100644
--- a/taskflow/tests/unit/worker_based/test_pipeline.py
+++ b/taskflow/tests/unit/worker_based/test_pipeline.py
@@ -15,6 +15,7 @@
 #    under the License.
 
 import futurist
+from futurist import waiters
 from oslo_utils import uuidutils
 
 from taskflow.engines.action_engine import executor as base_executor
@@ -24,7 +25,6 @@ from taskflow.engines.worker_based import server as worker_server
 from taskflow import test
 from taskflow.tests import utils as test_utils
 from taskflow.types import failure
-from taskflow.utils import async_utils
 from taskflow.utils import threading_utils
 
 
@@ -78,7 +78,7 @@ class TestPipeline(test.TestCase):
         progress_callback = lambda *args, **kwargs: None
         f = executor.execute_task(t, uuidutils.generate_uuid(), {},
                                   progress_callback=progress_callback)
-        async_utils.wait_for_any([f])
+        waiters.wait_for_any([f])
 
         event, result = f.result()
         self.assertEqual(1, result)
@@ -94,7 +94,7 @@ class TestPipeline(test.TestCase):
         progress_callback = lambda *args, **kwargs: None
         f = executor.execute_task(t, uuidutils.generate_uuid(), {},
                                   progress_callback=progress_callback)
-        async_utils.wait_for_any([f])
+        waiters.wait_for_any([f])
 
         action, result = f.result()
         self.assertIsInstance(result, failure.Failure)