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")