Create directory later

jan-janssen · jan-janssen · commit 6d8e451eada1 · 2025-07-11T11:02:01.000+02:00
diff --git a/executorlib/task_scheduler/file/task_scheduler.py b/executorlib/task_scheduler/file/task_scheduler.py
@@ -62,7 +62,6 @@ def __init__(
         if execute_function == execute_in_subprocess and terminate_function is None:
             terminate_function = terminate_subprocess
         cache_directory_path = os.path.abspath(cache_directory)
-        os.makedirs(cache_directory_path, exist_ok=True)
         self._process_kwargs = {
             "future_queue": self._future_queue,
             "execute_function": execute_function,
diff --git a/executorlib/task_scheduler/interactive/shared.py b/executorlib/task_scheduler/interactive/shared.py
@@ -160,7 +160,6 @@ def _execute_task_with_cache(
         resource_dict=task_dict.get("resource_dict", {}),
         cache_key=cache_key,
     )
-    os.makedirs(cache_directory, exist_ok=True)
     file_name = os.path.abspath(os.path.join(cache_directory, task_key + "_o.h5"))
     if file_name not in get_cache_files(cache_directory=cache_directory):
         f = task_dict.pop("future")

Original file line number	Diff line number	Diff line change
`@@ -160,7 +160,6 @@ def _execute_task_with_cache(`
`160`	`160`	`resource_dict=task_dict.get("resource_dict", {}),`
`161`	`161`	`cache_key=cache_key,`
`162`	`162`	`)`
`163`		`- os.makedirs(cache_directory, exist_ok=True)`
`164`	`163`	`file_name = os.path.abspath(os.path.join(cache_directory, task_key + "_o.h5"))`
`165`	`164`	`if file_name not in get_cache_files(cache_directory=cache_directory):`
`166`	`165`	`f = task_dict.pop("future")`