aboutsummaryrefslogtreecommitdiffstats
path: root/python/manual_trade_upload.py
blob: 24e7f9845d1e6bff4cab9fd0344359f1a80270a3 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
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)