diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 2b99831c..cae2d369 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -326,13 +326,13 @@ def upload_file(timestamp, queue_name='bond_trades'): ftp.cwd('incoming') filename = get_filename(timestamp, queue_name) cmd = 'STOR {0}'.format(filename) - with open(os.path.join('/home/share/Daily', str(timestamp.date()), filename), 'rb') as fh: + with open(os.path.join('/home/serenitas/Daily', str(timestamp.date()), filename), 'rb') as fh: ftp.storbinary(cmd, fh) def write_buffer(buf, queue_name='bond_trades'): timestamp = pd.datetime.now() filename = get_filename(timestamp, queue_name) - with open(os.path.join('/home/share/Daily', str(timestamp.date()), filename), 'wb') as fh: + with open(os.path.join('/home/serenitas/Daily', str(timestamp.date()), filename), 'wb') as fh: fh.write(buf) return timestamp |