1 files changed, 2 insertions, 8 deletions
diff --git a/python/citco_submission.py b/python/citco_submission.py
index ea3b41cd..a6c46aa1 100644
--- a/python/citco_submission.py
+++ b/python/citco_submission.py
@@ -6,18 +6,12 @@ from paramiko.ssh_exception import SSHException
 import logging
 
 
-@contextmanager
-def retry_on_exception_sftp():
-    yield
-
-
 def close_and_reconnect():
     retries = 5
     for i in range(retries):
         try:
-            with retry_on_exception_sftp():
-                CitcoSubmission._sftp.client.close()
-                CitcoSubmission.init_sftp()
+            CitcoSubmission._sftp.client.close()
+            CitcoSubmission.init_sftp()
         except (SSHException, OSError) as e:
             if i == retries - 1:
                 raise e