diff options
Diffstat (limited to 'python/report_ops')
| -rw-r--r-- | python/report_ops/__main__.py | 2 | ||||
| -rw-r--r-- | python/report_ops/utils.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/python/report_ops/__main__.py b/python/report_ops/__main__.py index 02cbc206..da634f74 100644 --- a/python/report_ops/__main__.py +++ b/python/report_ops/__main__.py @@ -114,10 +114,8 @@ if args.payment_settlements: conn = dbconn("dawndb") for fund in ("SERCGMAST", "BRINKER", "BOWDST", "ISOSEL"): notify_payment_settlements(args.date, fund, conn) - PaymentMonitor._staging_queue.clear() if args.fx_hedge: conn = dbconn("dawndb") for fund in ("SERCGMAST", "BOWDST", "ISOSEL"): notify_fx_hedge(cob, fund, conn) - FxHedge._staging_queue.clear() diff --git a/python/report_ops/utils.py b/python/report_ops/utils.py index bb6c0116..033195aa 100644 --- a/python/report_ops/utils.py +++ b/python/report_ops/utils.py @@ -82,6 +82,7 @@ def notify_payment_settlements(date, fund, conn): d["settlement_amount"] = d["payment_amount"] PaymentMonitor.stage(d) PaymentMonitor.email(fund) + PaymentMonitor._staging_queue.clear() def notify_fx_hedge(date, fund, conn): @@ -96,6 +97,7 @@ def notify_fx_hedge(date, fund, conn): d["category"] = "FCM" FxHedge.stage(d) FxHedge.email(fund) + FxHedge._staging_queue.clear() @dataclass |