1 files changed, 3 insertions, 3 deletions
diff --git a/python/process_queue.py b/python/process_queue.py
index 9f0e6f47..125a7a27 100644
--- a/python/process_queue.py
+++ b/python/process_queue.py
@@ -15,7 +15,7 @@ import os
 from sqlalchemy import create_engine
 from bbg_helpers import init_bbg_session, retrieve_data, BBG_IP
 import re
-import psycopg2
+from db import dbconn
 import logging
 import argparse
 
@@ -204,9 +204,9 @@ if __name__=="__main__":
     parser = argparse.ArgumentParser()
     parser.add_argument("-n", "--no-upload", action="store_true", help="do not upload to Globeop")
     args = parser.parse_args()
-    engine = create_engine('postgresql://dawn_user@debian/dawndb')
-    conn = engine.raw_connection()
     q = get_redis_queue()
+    serenitasdb = dbconn('serenitasdb')
+    dawndb = dbconn('dawndb')
     for queue_name in ['bond_trades', 'cds_trades']:
         l = get_trades(q, queue_name)
         if l: