adding special case situation

ssh2ssh.py

@@ -57,16 +57,18 @@ def copy(**context):
         sftp_client = source_ssh_hook.get_conn().open_sftp()
         sclient = RFSC(sftp_client)
 
+        target_conn = target_ssh_hook.get_conn()
+
         mappings = list(walk_dir(client=sclient, path=s_params["path"], prefix=""))
         for fname in mappings:
             target_name = fname.replace(s_params["path"], t_params["path"])
             print("Processing", fname, "-->", target_name)
 
             di = os.path.dirname(target_name)
             print("Making direcotry", di)
-            target_ssh_hook.get_conn().exec_command(command=f"mkdir -p {di}")
+            target_conn.exec_command(command=f"mkdir -p {di}")
             # sometimes mkdir takes longer and is not sync?
-            target_ssh_hook.get_conn().exec_command(command=f"touch {target_name}")
+            target_conn.exec_command(command=f"touch {target_name}")
 
             with target_client.open(target_name, "wb") as tr:
                 tr.set_pipelined(pipelined=True)

utils.py

@@ -221,6 +221,12 @@ def __init__(self, client, **kwargs):
         self.client = client
 
     def list(self, path, get_info=True):
+        if file_exist(self.client, path) and not is_dir(self.client, path):
+            print("Special case it is a file")
+            if not get_info:
+                return [path]
+            return [{"path": path, "isdir": False}]
+
         if not get_info:
             return [el.filename for el in self.client.listdir_attr(path)]
         return [