fixes

Author: jan-janssen

src/executorlib/task_scheduler/interactive/blockallocation.py

@@ -208,7 +208,7 @@ def _execute_multiple_tasks(
     queue_join_on_shutdown: bool = True,
     log_obj_size: bool = False,
     error_log_file: Optional[str] = None,
-    worker_id: Optional[int] = None,
+    worker_id: int = 0,
     stop_function: Optional[Callable] = None,
     restart_limit: int = 0,
     **kwargs,

tests/unit/executor/test_flux_job.py

@@ -113,8 +113,8 @@ def test_single_task(self):
     def test_output_files_cwd(self):
         dirname = os.path.abspath(os.path.join(os.path.dirname(__file__), "..", "..", ".."))
         os.makedirs(dirname, exist_ok=True)
-        file_stdout = os.path.join(dirname, "flux.out")
-        file_stderr = os.path.join(dirname, "flux.err")
+        file_stdout = os.path.join(dirname, "flux0.out")
+        file_stderr = os.path.join(dirname, "flux0.err")
         with FluxJobExecutor(
             max_cores=1,
             resource_dict={"cores": 1, "cwd": dirname},
@@ -133,8 +133,8 @@ def test_output_files_cwd(self):
         os.remove(file_stderr)
 
     def test_output_files_abs(self):
-        file_stdout = os.path.abspath("flux.out")
-        file_stderr = os.path.abspath("flux.err")
+        file_stdout = os.path.abspath("flux0.out")
+        file_stderr = os.path.abspath("flux0.err")
         with FluxJobExecutor(
             max_cores=1,
             resource_dict={"cores": 1},