import sys

from serenitas.ops.funds import Service
from serenitas.ops.trade_dataclasses import DealKind

asset_class = "termination"
trade_ids = [394]

buffers = []
for tradeid in trade_ids:
    buf = list(DealKind[asset_class].from_tradeid(tradeid).to_citco("NEW"))
    buffers.extend(buf)
Service["ISOSEL"].staging_queue.extend(buffers)
Service["ISOSEL"].build_buffer(asset_class)