diff options
Diffstat (limited to 'python/citco_submission.py')
| -rw-r--r-- | python/citco_submission.py | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/python/citco_submission.py b/python/citco_submission.py index fcef1ac4..4ba9a832 100644 --- a/python/citco_submission.py +++ b/python/citco_submission.py @@ -2,6 +2,7 @@ from stat import S_ISREG import time from citco_ops.utils import CitcoSubmission from paramiko.ssh_exception import SSHException +import logging def run(): @@ -10,14 +11,17 @@ def run(): try: for f in CitcoSubmission._sftp.client.listdir_iter(): if S_ISREG(f.st_mode): - CitcoSubmission.process(f.filename) - CitcoSubmission.check_cache() - - CitcoSubmission.commit() + try: + CitcoSubmission.process(f.filename) + except ValueError as e: + logging.error(e) + continue + CitcoSubmission.commit() except (SSHException, OSError): CitcoSubmission._sftp.client.close() CitcoSubmission.init_sftp() time.sleep(60) + CitcoSubmission.check_cache() if __name__ == "__main__": |