implicit mkdir on local agent staging

radical-cybertools · Apr 10, 2024 · b74bed2 · b74bed2
1 parent 659811c
commit b74bed2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/radical/pilot/agent/staging_input/default.py b/src/radical/pilot/agent/staging_input/default.py
@@ -191,6 +191,7 @@ def _handle_task(self, task, actionables):
 
             if action == rpc.COPY:
                 try:
+                    ru.rec_makedir(os.path.dirname(tgt.path))
                     shutil.copytree(src.path, tgt.path)
                 except OSError as exc:
                     if exc.errno == errno.ENOTDIR:

diff --git a/src/radical/pilot/agent/staging_output/default.py b/src/radical/pilot/agent/staging_output/default.py
@@ -319,6 +319,7 @@ def _handle_task_staging(self, task, actionables):
 
             if action == rpc.COPY:
                 try:
+                    ru.rec_makedir(os.path.dirname(tgt.path))
                     shutil.copytree(src.path, tgt.path)
                 except OSError as exc:
                     if exc.errno == errno.ENOTDIR: