diff options
| -rw-r--r-- | python/admin_cls_upload.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/python/admin_cls_upload.py b/python/admin_cls_upload.py index 1f9d9d88..e8bb0f6e 100644 --- a/python/admin_cls_upload.py +++ b/python/admin_cls_upload.py @@ -1,5 +1,7 @@ import datetime +import argparse from itertools import groupby + from serenitas.ops.trade_dataclasses import SpotDeal from report_ops.services import get_service @@ -8,7 +10,7 @@ from report_ops.services import get_service def upload_cls_file(conn, fund, trade_date, upload): with conn.cursor() as c: c.execute( - "SELECT ft.*, accounts2.cp_code as account_counterparty FROM forward_trades ft LEFT JOIN accounts2 USING (cash_account) WHERE ft.fund=%s AND ft.settle_date=%s AND accounts2.account_type='Cash';", + "SELECT ft.*, accounts2.cp_code as account_counterparty FROM forward_trades ft LEFT JOIN accounts2 USING (cash_account) WHERE ft.fund=%s AND ft.trade_date=%s AND accounts2.account_type='Cash';", (fund, trade_date), ) trades = [t._asdict() for t in c] @@ -50,4 +52,4 @@ if __name__ == "__main__": args = parser.parse_args() conn = SpotDeal._conn for fund in ("BOWDST",): - upload_cls_file(conn, fund, args.trade_date, not args.no_uplaod) + upload_cls_file(conn, fund, args.trade_date, not args.no_upload) |