import sys

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

trade_ids = [1]

buffers = []
for tradeid in trade_ids:
    buffers.append(IRSDeal.from_tradeid(tradeid).product.to_citco())
SeleneProd.staging_queue.extend(buffers)
SeleneProd.build_buffer()