diff options
Diffstat (limited to 'python/citco_submission.py')
| -rw-r--r-- | python/citco_submission.py | 27 |
1 files changed, 13 insertions, 14 deletions
diff --git a/python/citco_submission.py b/python/citco_submission.py index 629d0626..91ac5ed2 100644 --- a/python/citco_submission.py +++ b/python/citco_submission.py @@ -8,8 +8,6 @@ from report_ops.status import CitcoSubmission logging.basicConfig(level=logging.INFO) logger = logging.getLogger(__name__) -fund_sftp = {"ISOSEL": ("citco", "/outgoing/notifications")} - def close_and_reconnect(creds, folder): retries = 5 @@ -28,18 +26,19 @@ def close_and_reconnect(creds, folder): def run(): while True: - for fund, (creds, folder) in fund_sftp.items(): - CitcoSubmission.init_client(creds, folder=folder) - try: - for f in CitcoSubmission._client.client.listdir_iter(folder): - if S_ISREG(f.st_mode): - try: - CitcoSubmission.process(f.filename) - except ValueError as e: - logger.info(f"{fund}: {e}") - except (SSHException, OSError) as e: - logger.info(e) - close_and_reconnect(creds, folder) + CitcoSubmission.init_client("citco", folder="/outgoing/notifications") + try: + for f in CitcoSubmission._client.client.listdir_iter( + "/outgoing/notifications" + ): + if S_ISREG(f.st_mode): + try: + CitcoSubmission.process(f.filename) + except ValueError as e: + logger.info(f"{e}") + except (SSHException, OSError) as e: + logger.info(e) + close_and_reconnect("citco", "/outgoing/notifications") time.sleep(60) CitcoSubmission.check_cache() |