fix for non standard ssh sftp port

Aiven-Open · Apr 27, 2022 · 4b6456b · 4b6456b
1 parent c196147
commit 4b6456b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/rohmu/object_storage/sftp.py b/rohmu/object_storage/sftp.py
@@ -14,6 +14,7 @@
 import logging
 import os
 import paramiko
+import warnings
 
 
 class SFTPTransfer(BaseTransfer):
@@ -36,7 +37,10 @@ def __init__(self,
 
         logging.getLogger("paramiko").setLevel(logging.WARNING)
 
-        transport = paramiko.Transport(self.server, self.port)
+        # https://github.com/paramiko/paramiko/issues/1386#issuecomment-470847772
+        warnings.filterwarnings(action='ignore', module='.*paramiko.*')
+
+        transport = paramiko.Transport((self.server, self.port))
 
         if private_key:
             pkey = paramiko.RSAKey.from_private_key_file(self.private_key)