diff --git a/dags/taskflow.py b/dags/taskflow.py
index 3e18ad6be24a9eefd3be6fc5844a71e7efc63342..f00db9cdd2f990af38354376f9fb38625d28992c 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)}")