diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/gfs_monitor.py | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/python/gfs_monitor.py b/python/gfs_monitor.py index 17413d89..a6e95f59 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 periodenddate =%s;", + "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;", ( fund, date, @@ -54,6 +54,9 @@ if __name__ == "__main__": args = parser.parse_args() logger = logging.getLogger(__name__) conn = dbconn("dawndb") - for fund in ("SERCGMAST",): + for fund in ( + "SERCGMAST", + "BOWDST", + ): check_gfs(args.cob, fund, conn) - # check_cleared_cds(args.cob, fund, conn) + check_cleared_cds(args.cob, fund, conn) |