extend test

Author: jan-janssen

tests/test_fluxclusterexecutor.py

@@ -11,6 +11,7 @@
     import flux.job
     from executorlib.task_scheduler.file.hdf import dump
     from executorlib.task_scheduler.file.queue_spawner import terminate_with_pysqa, terminate_tasks_in_cache, execute_with_pysqa
+    from executorlib.task_scheduler.file.shared import _get_execute_command
 
     skip_flux_test = "FLUX_URI" not in os.environ
     pmi = os.environ.get("EXECUTORLIB_PMIX", None)
@@ -62,9 +63,13 @@ def test_executor_no_cwd(self):
 
     def test_pysqa_interface(self):
         queue_id = execute_with_pysqa(
-            command=["flux", "run", "sleep", "10"],
-            file_name="test.h5",
-            data_dict={"fn": sleep},
+            command=_get_execute_command(
+                file_name="test_i.h5",
+                cores=1,
+            ),
+            file_name="test_i.h5",
+            data_dict={"fn": sleep, "args": (10,)},
+            resource_dict={"cores": 1},
             cache_directory="executorlib_cache",
             backend="flux"
         )