1 files changed, 9 insertions, 6 deletions
diff --git a/python/gfs_monitor.py b/python/gfs_monitor.py
index a6e95f59..11e0b197 100644
--- a/python/gfs_monitor.py
+++ b/python/gfs_monitor.py
@@ -54,9 +54,12 @@ if __name__ == "__main__":
     args = parser.parse_args()
     logger = logging.getLogger(__name__)
     conn = dbconn("dawndb")
-    for fund in (
-        "SERCGMAST",
-        "BOWDST",
-    ):
-        check_gfs(args.cob, fund, conn)
-        check_cleared_cds(args.cob, fund, conn)
+    sql_str = "SELECT endqty as payment_amount, invccy as currency, periodenddate as settle_date FROM valuation_reports vr WHERE fund=%s AND port ='GFS_HELPER_BUSINESS_UNIT' AND periodenddate =%s AND abs(endqty) > 50000;"
+    em = ExchangeMessage()
+    with conn.cursor() as c:
+        for fund in ("BOWDST", "SERCGMAST"):
+            c.execute(sql_str, (fund, args.cob))
+            for row in c:
+                GFSMonitor.stage(c._asdict())
+            GFSMonitor.email(fund)
+            GFSMonitor._insert_queue.clear()