diff options
| -rw-r--r-- | python/book_bbg2.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/python/book_bbg2.py b/python/book_bbg2.py index 77fdaf74..46d62f0b 100644 --- a/python/book_bbg2.py +++ b/python/book_bbg2.py @@ -102,6 +102,7 @@ def bond_booking_process(path, conn): BondDeal.commit() df.columns.index = "bbg_trade_id" df.index = [get_bbg_id(path.name)] + df.to_sql("bond_tickets", dawn_engine, if_exists="append") def get_bbg_id(name): @@ -123,7 +124,7 @@ if __name__ == "__main__": continue else: if "CDX" in f.name: - cds_booking_process(sftp.get(f), d, conn, dawn_engine) + cds_booking_process(sftp.get(f), conn) elif "BOND" in f.name: - bond_booking_process(sftp.get(f), d, conn, dawn_engine) + bond_booking_process(sftp.get(f), conn) _cache[get_bbg_id(f.name)] = None |