Fix blockallocation test call sites

Author: Copilot

tests/unit/executor/test_single_shell_executor.py

@@ -34,6 +34,7 @@ def test_execute_single_task(self):
         self.assertFalse(f.done())
         _execute_multiple_tasks(
             future_queue=test_queue,
+            return_queue=queue.Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -60,6 +61,7 @@ def test_wrong_error(self):
         with self.assertRaises(TypeError):
             _execute_multiple_tasks(
                 future_queue=test_queue,
+                return_queue=queue.Queue(),
                 cores=1,
                 openmpi_oversubscribe=False,
                 spawner=MpiExecSpawner,
@@ -87,6 +89,7 @@ def test_broken_executable(self):
         with self.assertRaises(FileNotFoundError):
             _execute_multiple_tasks(
                 future_queue=test_queue,
+                return_queue=queue.Queue(),
                 cores=1,
                 openmpi_oversubscribe=False,
                 spawner=MpiExecSpawner,

tests/unit/executor/test_single_shell_interactive.py

@@ -90,6 +90,7 @@ def test_execute_single_task(self):
         self.assertFalse(future_pattern.done())
         _execute_multiple_tasks(
             future_queue=test_queue,
+            return_queue=queue.Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,

tests/unit/standalone/interactive/test_spawner.py

@@ -263,6 +263,7 @@ def test_execute_task(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -445,6 +446,7 @@ def test_execute_task_failed_no_argument(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -461,6 +463,7 @@ def test_execute_task_failed_wrong_argument(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -477,6 +480,7 @@ def test_execute_task(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -495,6 +499,7 @@ def test_execute_task_parallel(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=2,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -518,6 +523,7 @@ def test_execute_task_cache(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,
@@ -537,6 +543,7 @@ def test_execute_task_cache_failed_no_argument(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             openmpi_oversubscribe=False,
             spawner=MpiExecSpawner,

tests/unit/task_scheduler/interactive/test_spawner_flux.py

@@ -113,6 +113,7 @@ def test_execute_task(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             flux_executor=self.flux_executor,
             spawner=FluxPythonSpawner,
@@ -128,6 +129,7 @@ def test_execute_task_threads(self):
         cloudpickle_register(ind=1)
         _execute_multiple_tasks(
             future_queue=q,
+            return_queue=Queue(),
             cores=1,
             threads_per_core=1,
             flux_executor=self.flux_executor,