diff options
| -rw-r--r-- | python/collateral/__main__.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/collateral/__main__.py b/python/collateral/__main__.py index 1e43108f..93305bd9 100644 --- a/python/collateral/__main__.py +++ b/python/collateral/__main__.py @@ -122,8 +122,10 @@ for fund in funds: ) positions_rates = pd.read_sql_query( "SELECT cleared_trade_id, notional, effective_date, maturity_date, payreceive, fixed_rate, folder, currency " - "FROM irs", + "FROM irs " + "WHERE fund=%s", dawn_engine, + params=(fund_mapping[fund],), index_col=["cleared_trade_id"], parse_dates=["effective_date", "maturity_date"], ) |