diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/trade_dataclasses.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/python/trade_dataclasses.py b/python/trade_dataclasses.py index 5e8d5176..02a209ce 100644 --- a/python/trade_dataclasses.py +++ b/python/trade_dataclasses.py @@ -416,10 +416,11 @@ class BondDeal(BbgDeal, Deal, deal_type=DealType.Bond, table_name="bonds"): cls._bbg_insert_queue.append(list(line.values())) with cls._conn.cursor() as c: c.execute( - "SELECT asset_class from securities where identifier=%s", - (line["Cusip"],), + "SELECT asset_class from securities where figi=%s", + (line["FIGI"],), ) - line["asset_class"] = c.fetchone() + results = c.fetchone() + line["asset_class"] = results[0] if results else None return cls( faceamount=Decimal(line["Quantity"]), price=Decimal(line["Price (Dec)"]), |