Skip to content

Commit 45941f6

Browse files
committed
fix file checks
1 parent 2b049e5 commit 45941f6

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

executorlib/task_scheduler/file/shared.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ def execute_tasks_h5(
102102
{k: v for k, v in resource_dict.items() if k not in task_resource_dict}
103103
)
104104
cache_key = task_resource_dict.pop("cache_key", None)
105-
cache_directory = task_resource_dict.pop("cache_directory")
105+
cache_directory = os.path.abspath(task_resource_dict.pop("cache_directory"))
106106
task_key, data_dict = serialize_funct_h5(
107107
fn=task_dict["fn"],
108108
fn_args=task_args,

executorlib/task_scheduler/file/task_scheduler.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,9 +93,9 @@ def create_file_executor(
9393
disable_dependencies: bool = False,
9494
):
9595
if cache_directory is None:
96-
resource_dict["cache_directory"] = os.path.abspath("executorlib_cache")
96+
resource_dict["cache_directory"] = "executorlib_cache"
9797
else:
98-
resource_dict["cache_directory"] = os.path.abspath(cache_directory)
98+
resource_dict["cache_directory"] = cache_directory
9999
if block_allocation:
100100
raise ValueError(
101101
"The option block_allocation is not available with the pysqa based backend."

0 commit comments

Comments
 (0)