blob: 3b7b6e873cabd481fb94e76f173e5c7cc5d22445 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
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")
|
