From 8bfabd2c62cd3a5618f76420cd32fd8a94bb9057 Mon Sep 17 00:00:00 2001
From: jrybicki-jsc <j.rybicki@fz-juelich.de>
Date: Wed, 23 Mar 2022 11:30:59 +0100
Subject: [PATCH] mkdir p on target

---
 dags/taskflow.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dags/taskflow.py b/dags/taskflow.py
index 3e18ad6..f00db9c 100644
--- a/dags/taskflow.py
+++ b/dags/taskflow.py
@@ -63,7 +63,7 @@ def taskflow_example():
         with ssh_hook.get_conn() as ssh_client:
             sftp_client = ssh_client.open_sftp()
             # check dir?
-            sftp_client.mkdir(target, ignore_existing=True)
+            ssh_client.exec_command(command=f"mkdir -p {target}")
             for [truename, local] in files.items():
                 print(
                     f"Copying {local} --> {connection_id}:{os.path.join(target, truename)}")
-- 
GitLab