diff options
Diffstat (limited to 'python/gfs_monitor.py')
| -rw-r--r-- | python/gfs_monitor.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/python/gfs_monitor.py b/python/gfs_monitor.py index 02017c1d..57f44087 100644 --- a/python/gfs_monitor.py +++ b/python/gfs_monitor.py @@ -9,7 +9,7 @@ from report_ops.utils import GFSMonitor, CDXQuoteMonitor def check_gfs(date, fund, conn): with conn.cursor() as c: c.execute( - "SELECT endqty as amount, invccy as currency, periodenddate as date, port as portfolio FROM valuation_reports vr WHERE fund=%s AND port ='GFS_HELPER_BUSINESS_UNIT' AND abs(endqty) > 50000 AND periodenddate =%s;", + "SELECT endqty as amount, invccy as currency, periodenddate as date, port as portfolio FROM valuation_reports vr WHERE fund=%s AND abs(endqty) > 50000 AND port ='GFS_HELPER_BUSINESS_UNIT' AND periodenddate =%s;", ( fund, date, @@ -54,9 +54,9 @@ if __name__ == "__main__": args = parser.parse_args() logger = logging.getLogger(__name__) conn = dbconn("dawndb") - 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"): - check_gfs(args.cob, fund, conn) - check_cleared_cds(args.cob, fund, conn) + for fund in ( + "SERCGMAST", + "BOWDST", + ): + check_gfs(args.cob, fund, conn) + check_cleared_cds(args.cob, fund, conn) |