diff options
| -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 04cde666..5b489625 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -421,7 +421,7 @@ def get_filepath(base_dir: pathlib.Path, queue_name: str) -> pathlib.Path: 'future_trades': 'Future', 'wires': 'CashFlowDeal', 'spot_trades': 'SpotDeal'} - timestamp = datetime.date.now() + timestamp = datetime.datetime.now() return (base_dir / str(timestamp.date()) / f'Serenitas.ALL.{timestamp:%Y%m%d.%H%M%S}.{d[queue_name]}.csv') @@ -430,7 +430,7 @@ def upload_file(file_path: pathlib.Path, queue_name: str = 'bond_trades') -> Non ftp = FTP('ftp.globeop.com') ftp.login('srntsftp', config.ftp_password) ftp.cwd('incoming') - cmd = f"STOR {filename}" + cmd = f"STOR {file_path.name}" with file_path.open("rb") as fh: ftp.storbinary(cmd, fh) |