diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/reallocate_iam.py | 2 | ||||
| -rw-r--r-- | python/strat_cash_realloc.py | 11 |
2 files changed, 6 insertions, 7 deletions
diff --git a/python/reallocate_iam.py b/python/reallocate_iam.py index de5dd1fd..52d199b7 100644 --- a/python/reallocate_iam.py +++ b/python/reallocate_iam.py @@ -3,7 +3,7 @@ import datetime from collections import defaultdict from psycopg2.errors import UniqueViolation from serenitas.analytics.dates import bus_day -from serenitas.ops.funds import Fund +from serenitas.ops.funds import Service _iam_brokers = { "BAML_ISDA": "BOANNY", diff --git a/python/strat_cash_realloc.py b/python/strat_cash_realloc.py index dd7a15ae..2bfc9f15 100644 --- a/python/strat_cash_realloc.py +++ b/python/strat_cash_realloc.py @@ -1,5 +1,5 @@ from serenitas.utils.db import dbconn -from serenitas.ops.funds import Fund +from serenitas.ops.funds import Bowdst import datetime from serenitas.analytics.dates import prev_business_day from collateral.common import CASH_STRATEGY_MAPPING, STRATEGY_CASH_MAPPING @@ -7,7 +7,6 @@ from serenitas.utils.misc import rename_keys def generate_csv(date, conn): - bowdst = Fund["BOWDST"]() with conn.cursor() as c, conn.cursor() as d: c.execute( "SELECT vr.*, accounts2.custodian, accounts2.cp_code, pfm.folder AS dirty_strat FROM (SELECT sum(endqty) AS endqty, port, strat, custacctname, invid FROM valuation_reports v WHERE periodenddate =%s AND fund='BOWDST' AND invid IN ('USD', 'EUR') AND port NOT IN ('GFS_HELPER_BUSINESS_UNIT', 'CASH') GROUP BY (port, strat,custacctname, invid) HAVING sum(endqty) !=0) vr LEFT JOIN accounts2 ON custacctname=cash_account LEFT JOIN portfolio_folder_mapping pfm ON vr.strat::text=pfm.clean_folder where strat is not NULL;", @@ -59,11 +58,11 @@ def generate_csv(date, conn): offset["Deal Id"] = obj["Deal Id"] + "_O" offset["Amount"] = -obj["Amount"] offset["Folder"] = STRATEGY_CASH_MAPPING[obj["Folder"]] - bowdst.staging_queue.extend([obj, offset]) + Bowdst.staging_queue.extend([obj, offset]) conn.commit() - if bowdst.staging_queue: - buf, dest = bowdst.build_buffer("wire") - bowdst.upload(buf, dest.name) + if Bowdst.staging_queue: + buf, dest = Bowdst.build_buffer("wire") + Bowdst.upload(buf, dest.name) if __name__ == "__main__": |