diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/strat_cash_realloc.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/strat_cash_realloc.py b/python/strat_cash_realloc.py index 5cf1695d..0ef57cee 100644 --- a/python/strat_cash_realloc.py +++ b/python/strat_cash_realloc.py @@ -1,6 +1,5 @@ from serenitas.utils.db import dbconn from serenitas.utils.env import DAILY_DIR -from headers import get_headers from process_queue import get_filepath import datetime import csv @@ -9,12 +8,13 @@ from serenitas.analytics.dates import prev_business_day from serenitas.utils.remote import SftpClient from collateral.common import CASH_STRATEGY_MAPPING, STRATEGY_CASH_MAPPING from serenitas.utils.misc import rename_keys +from csv_headers.globeop_upload import HEADERS def process_upload(trades): buf = StringIO() csvwriter = csv.writer(buf) - headers = get_headers("wire", "BOWDST") + headers = HEADERS["wire"] csvwriter.writerow(headers) csvwriter.writerows(trades) buf = buf.getvalue().encode() @@ -27,7 +27,7 @@ def process_upload(trades): def generate_csv(date, conn): - headers = get_headers("wire", "BOWDST") + headers = HEADERS["wire"] 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 ='2022-05-19' 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 pfm.folder is not NULL;", |