aboutsummaryrefslogtreecommitdiffstats
path: root/python/citco_submission2.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/citco_submission2.py')
-rw-r--r--python/citco_submission2.py47
1 files changed, 0 insertions, 47 deletions
diff --git a/python/citco_submission2.py b/python/citco_submission2.py
deleted file mode 100644
index 6ded8224..00000000
--- a/python/citco_submission2.py
+++ /dev/null
@@ -1,47 +0,0 @@
-import time
-import logging
-from stat import S_ISREG
-from paramiko.ssh_exception import SSHException
-
-from report_ops.status import CitcoSubmission
-
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
-
-
-def close_and_reconnect():
- retries = 5
- for i in range(retries):
- try:
- CitcoSubmission._client.client.close()
- CitcoSubmission.init_client("citco", folder="/outgoing/notifications")
- except (SSHException, OSError) as e:
- if i == retries - 1:
- raise e
- else:
- time.sleep(60 * i)
- else:
- return
-
-
-def run():
- CitcoSubmission.init_client("citco", folder="/outgoing/notifications")
- while True:
- 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(e)
- except (SSHException, OSError) as e:
- logger.info(e)
- close_and_reconnect()
- time.sleep(60)
- CitcoSubmission.check_cache()
-
-
-if __name__ == "__main__":
- run()