1 files changed, 4 insertions, 4 deletions
diff --git a/python/markit_loans.py b/python/markit_loans.py
index 1cc99739..f0e9d9a9 100644
--- a/python/markit_loans.py
+++ b/python/markit_loans.py
@@ -1,13 +1,13 @@
 import requests
 from common import root
-from db import conn, with_connection
+from db import with_connection
 import os
 import datetime
 import csv
 import sys
 import logging
 
-@with_connection
+@with_connection('etdb')
 def download_facility(conn, workdate, payload):
     r = requests.get('https://loans.markit.com/loanx/LoanXFacilityUpdates.csv', params=payload)
     facility_filename = os.path.join(root, "data", "Facility files", "facility_{0}.csv".format(workdate))
@@ -26,7 +26,7 @@ def download_facility(conn, workdate, payload):
                 c.execute(sqlstring, newline)
         conn.commit()
 
-@with_connection
+@with_connection('etdb')
 def download_marks(conn, workdate, payload):
     r = requests.get('https://loans.markit.com/loanx/LoanXMarks.csv', params=payload)
     marks_filename = os.path.join(root, "data", "markit", "markit_data_{0}.csv".format(workdate))
@@ -46,7 +46,7 @@ def download_marks(conn, workdate, payload):
                                       line['Depth'], line['Mark Date']))
         conn.commit()
 
-@with_connection
+@with_connection('etdb')
 def update_facility(conn, workdate, payload):
     #we update the missing facility loanxids
     sqlstring = "SELECT loanxid FROM markit_prices EXCEPT SELECT loanxid FROM markit_facility";