fix tests

Author: jan-janssen

tests/unit/executor/test_single_dependencies.py

@@ -116,6 +116,7 @@ def test_dependency_steps(self):
         fs1 = Future()
         fs2 = Future()
         q = Queue()
+        qr = Queue()
         q.put(
             {
                 "fn": add_function,
@@ -150,6 +151,7 @@ def test_dependency_steps(self):
             target=_execute_tasks_with_dependencies,
             kwargs={
                 "future_queue": q,
+                "return_queue": qr,
                 "executor_queue": executor._future_queue,
                 "executor": executor,
                 "refresh_rate": 0.01,
@@ -168,6 +170,7 @@ def test_dependency_steps_error(self):
         fs1 = Future()
         fs2 = Future()
         q = Queue()
+        qr = Queue()
         q.put(
             {
                 "fn": raise_error,
@@ -202,6 +205,7 @@ def test_dependency_steps_error(self):
             target=_execute_tasks_with_dependencies,
             kwargs={
                 "future_queue": q,
+
                 "executor_queue": executor._future_queue,
                 "executor": executor,
                 "refresh_rate": 0.01,
@@ -222,6 +226,7 @@ def test_dependency_steps_error_before(self):
         fs1.set_exception(RuntimeError())
         fs2 = Future()
         q = Queue()
+        qr = Queue()
         q.put(
             {
                 "fn": add_function,
@@ -256,6 +261,7 @@ def test_dependency_steps_error_before(self):
             target=_execute_tasks_with_dependencies,
             kwargs={
                 "future_queue": q,
+                "return_queue": qr,
                 "executor_queue": executor._future_queue,
                 "executor": executor,
                 "refresh_rate": 0.01,