bug fixes

pyiron · Oct 27, 2024 · a813845 · a813845
1 parent 91d2e68
commit a813845
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/executorlib/cache/shared.py b/executorlib/cache/shared.py
@@ -93,7 +93,7 @@ def execute_tasks_h5(
                 memory_dict=memory_dict,
                 file_name_dict=file_name_dict,
             )
-            resource_dict = task_dict["resource_dict"]
+            resource_dict = task_dict["resource_dict"].copy()
             if "cores" not in resource_dict:
                 resource_dict["cores"] = cores_per_worker
             if "cwd" not in resource_dict:

diff --git a/executorlib/standalone/cache/spawner.py b/executorlib/standalone/cache/spawner.py
@@ -29,6 +29,8 @@ def execute_in_subprocess(
         ]
     if resource_dict is None:
         resource_dict = {"cwd": None}
+    elif len(resource_dict) == 0:
+        resource_dict = {"cwd": None}
     return subprocess.Popen(command, universal_newlines=True, cwd=resource_dict["cwd"])
 
 

diff --git a/tests/test_cache_executor_serial.py b/tests/test_cache_executor_serial.py
@@ -73,7 +73,6 @@ def test_executor_function(self):
                 "cache_directory": cache_dir,
                 "execute_function": execute_in_subprocess,
                 "cores_per_worker": 1,
-                "resource_dict": {"cwd": None},
                 "terminate_function": terminate_subprocess,
             },
         )
@@ -115,7 +114,6 @@ def test_executor_function_dependence_kwargs(self):
                 "cache_directory": cache_dir,
                 "execute_function": execute_in_subprocess,
                 "cores_per_worker": 1,
-                "resource_dict": {"cwd": None},
                 "terminate_function": terminate_subprocess,
             },
         )
@@ -157,7 +155,6 @@ def test_executor_function_dependence_args(self):
                 "cache_directory": cache_dir,
                 "execute_function": execute_in_subprocess,
                 "cores_per_worker": 1,
-                "resource_dict": {"cwd": None},
                 "terminate_function": terminate_subprocess,
             },
         )