diff options
| -rw-r--r-- | python/globeop_monitor.py | 4 | ||||
| -rw-r--r-- | python/innocap.py | 2 | ||||
| -rw-r--r-- | python/report_ops/__main__.py | 2 | ||||
| -rw-r--r-- | python/report_ops/utils.py | 16 |
4 files changed, 12 insertions, 12 deletions
diff --git a/python/globeop_monitor.py b/python/globeop_monitor.py index 413c569f..464a3a78 100644 --- a/python/globeop_monitor.py +++ b/python/globeop_monitor.py @@ -17,7 +17,7 @@ def check_gfs(date, fund, conn): for row in c: GFSMonitor.stage(row._asdict()) GFSMonitor.email(fund) - GFSMonitor._insert_queue.clear() + GFSMonitor._staging_queue.clear() def check_cleared_cds(date, fund, conn): @@ -36,7 +36,7 @@ def check_cleared_cds(date, fund, conn): if d["difference"] > 0.10: CDXQuoteMonitor.stage(d) CDXQuoteMonitor.email(fund) - CDXQuoteMonitor._insert_queue.clear() + CDXQuoteMonitor._staging_queue.clear() if __name__ == "__main__": diff --git a/python/innocap.py b/python/innocap.py index 191901f1..4e0f8603 100644 --- a/python/innocap.py +++ b/python/innocap.py @@ -79,7 +79,7 @@ def monitor_cash_balances(date, account, conn, upload): } ) SettlementMonitor.email(fund) - SettlementMonitor._insert_queue.clear() + SettlementMonitor._staging_queue.clear() else: raise ValueError(f"No cash balances parsed for account {account}: {cob}") diff --git a/python/report_ops/__main__.py b/python/report_ops/__main__.py index 5c3961e9..a6689e19 100644 --- a/python/report_ops/__main__.py +++ b/python/report_ops/__main__.py @@ -112,4 +112,4 @@ if args.payment_settlements: conn = dbconn("dawndb") for fund in ("SERCGMAST", "BRINKER", "BOWDST", "ISOSEL"): notify_payment_settlements(date, fund, conn) - PaymentMonitor._insert_queue.clear() + PaymentMonitor._staging_queue.clear() diff --git a/python/report_ops/utils.py b/python/report_ops/utils.py index 325a4179..3a673c9f 100644 --- a/python/report_ops/utils.py +++ b/python/report_ops/utils.py @@ -214,7 +214,7 @@ class Monitor: date: datetime.date headers: ClassVar = () num_format: ClassVar = [] - _insert_queue: ClassVar[list] = [] + _staging_queue: ClassVar[list] = [] _em: ClassVar = ExchangeMessage() def __init_subclass__(cls, headers, num_format=[]): @@ -223,11 +223,11 @@ class Monitor: @classmethod def stage(cls, d: dict): - cls._insert_queue.append(list(d[key] for key in cls.headers)) + cls._staging_queue.append(list(d[key] for key in cls.headers)) @classmethod def format(cls): - for line in cls._insert_queue: + for line in cls._staging_queue: for f, i in cls.num_format: line[i] = f.format(line[i]) @@ -235,7 +235,7 @@ class Monitor: def to_tabulate(cls): cls.format() t = tabulate( - cls._insert_queue, + cls._staging_queue, headers=cls.headers, tablefmt="unsafehtml", ) @@ -254,7 +254,7 @@ class GFSMonitor( ): @classmethod def email(cls, fund): - if not cls._insert_queue: + if not cls._staging_queue: return cls._em.send_email( f"GFS Helper Strategy Issue: {fund}", @@ -290,7 +290,7 @@ class CDXQuoteMonitor( ): @classmethod def email(cls, fund): - if not cls._insert_queue: + if not cls._staging_queue: return cls._em.send_email( f"CDX Quote Outside of our Tolerance: {fund}", @@ -320,7 +320,7 @@ class SettlementMonitor( ): @classmethod def email(cls, fund): - if not cls._insert_queue: + if not cls._staging_queue: return cls._em.send_email( f"*ACTION REQUESTED* Projected Overdraft: {fund}", @@ -359,7 +359,7 @@ class PaymentMonitor( ): @classmethod def email(cls, fund): - if not cls._insert_queue: + if not cls._staging_queue: return cls._em.send_email( f"Projected Settlements: {fund}", |