diff options
| -rw-r--r-- | python/manual_bond_upload.py | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/python/manual_bond_upload.py b/python/manual_bond_upload.py new file mode 100644 index 00000000..3b7b6e87 --- /dev/null +++ b/python/manual_bond_upload.py @@ -0,0 +1,14 @@ +from serenitas.ops.trade_dataclasses import BondDeal +from serenitas.utils.db import dbconn +from serenitas.ops.funds import Serenitas + + +conn = dbconn("dawndb") +with conn.cursor() as c: + c.execute( + "SELECT * from bond_trades WHERE settle_date > '2022-11-15' AND account= 'BAC'" + ) + for row in c: + trade = BondDeal.from_dict(**row._asdict(), scaled=True) + Serenitas.staging_queue.append(trade.to_globeop("UPDATE")) + Serenitas.build_buffer("bond") |