diff options
| -rw-r--r-- | python/gfs_monitor.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/gfs_monitor.py b/python/gfs_monitor.py index 9e3187bb..fe2da58a 100644 --- a/python/gfs_monitor.py +++ b/python/gfs_monitor.py @@ -19,7 +19,7 @@ if __name__ == "__main__": args = parser.parse_args() logger = logging.getLogger(__name__) conn = dbconn("dawndb") - sql_str = "SELECT endqty, invccy FROM valuation_reports vr WHERE fund=%s AND port ='GFS_HELPER_BUSINESS_UNIT' AND periodenddate =%s AND abs(endqty) > 50000;" + 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"): |