diff options
Diffstat (limited to 'python/globeop_monitor.py')
| -rw-r--r-- | python/globeop_monitor.py | 4 |
1 files changed, 2 insertions, 2 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__": |