diff options
Diffstat (limited to 'python/innocap_file_transfer.py')
| -rw-r--r-- | python/innocap_file_transfer.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/python/innocap_file_transfer.py b/python/innocap_file_transfer.py index 50d0cca4..db555a66 100644 --- a/python/innocap_file_transfer.py +++ b/python/innocap_file_transfer.py @@ -18,17 +18,19 @@ def concat_csv(file_type, date): for f in (DAILY_DIR / str(date)).iterdir(): if f.is_file() and f.name.startswith(file_tag): with f.open("rb") as fh: - next(fh) + next(fh) # Don't concat headers buf.write(fh.read()) - return buf, fname + return buf.getvalue(), fname def main(date, upload): for file_type in ("trade", "instrument"): buf, fname = concat_csv(file_type, date) + dest = DAILY_DIR / str(date) / fname + dest.write_bytes(buf) if upload: innocap_sftp = SftpClient.from_creds("innocap", folder="Innocap") - innocap_sftp.put(buf.getvalue(), fname) + innocap_sftp.put(buf, fname) if __name__ == "__main__": |