diff options
| -rw-r--r-- | python/citco_submission.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/python/citco_submission.py b/python/citco_submission.py index 32821fae..9974cd9d 100644 --- a/python/citco_submission.py +++ b/python/citco_submission.py @@ -214,12 +214,11 @@ def run(): from lru import LRU _cache = LRU(128) - sftp = SftpClient.from_creds("citco") + sftp = SftpClient.from_creds("citco", "/outgoing/notifications") while True: try: conn = dbconn("dawndb") em = ExchangeMessage() - sftp.client.chdir("/outgoing/notifications") for f in sftp.client.listdir_iter(): if S_ISREG(f.st_mode): is_processed, fname_short = get_citco_property(f.filename) @@ -230,7 +229,7 @@ def run(): _cache[fname_short] = None except (SSHException, OSError): sftp.client.close() - sftp = SftpClient.from_creds("citco") + sftp = SftpClient.from_creds("citco", "/outgoing/notifications") time.sleep(60) |