From 6d8e451eada10e4f69f3f8aebedc26e2829b7156 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jan=20Jan=C3=9Fen?= Date: Fri, 11 Jul 2025 11:02:01 +0200 Subject: [PATCH] Create directory later --- executorlib/task_scheduler/file/task_scheduler.py | 1 - executorlib/task_scheduler/interactive/shared.py | 1 - 2 files changed, 2 deletions(-) diff --git a/executorlib/task_scheduler/file/task_scheduler.py b/executorlib/task_scheduler/file/task_scheduler.py index 74eaccdd..a373d902 100644 --- 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 index 3742dcfc..7c27e043 100644 --- 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")