Create cache directory only during dump()

jan-janssen · jan-janssen · commit 833db95ad02d · 2025-07-11T08:14:49.000+02:00
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")`