import sys

sys.path.append("/home/flint/projects/ops/serenitas/")
from ops.funds import Fund
from ops.trade_dataclasses import DealKind

asset_class = "cds"
trade_ids = [4234, 4232, 4219, 4218]

buffers = []
for tradeid in trade_ids:
    if isinstance(DealKind[asset_class].from_tradeid(tradeid).to_citco("UPDATE"), list):
        buffers.extend(DealKind[asset_class].from_tradeid(tradeid).to_citco("UPDATE"))
    else:
        buffers.append(DealKind[asset_class].from_tradeid(tradeid).to_citco("UPDATE"))

Fund["ISOSEL"].staging_queue.extend(buffers)
Fund["ISOSEL"].build_buffer(asset_class)