aboutsummaryrefslogtreecommitdiffstats
path: root/python/markit_loans.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/markit_loans.py')
-rw-r--r--python/markit_loans.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/markit_loans.py b/python/markit_loans.py
index b61a680f..4853ec1d 100644
--- a/python/markit_loans.py
+++ b/python/markit_loans.py
@@ -32,7 +32,7 @@ def download_marks(conn, workdate, payload):
marks_filename = os.path.join(root, "data", "markit", "markit_data_{0}.csv".format(workdate))
with open(marks_filename, "wb") as fh:
fh.write(r.content)
- sqlstring = "INSERT INTO markit_prices2 VALUES( {0} )".format( ",".join([ "%s" ] * 5))
+ sqlstring = "INSERT INTO markit_prices VALUES( {0} )".format( ",".join([ "%s" ] * 5))
with open(marks_filename, "r") as fh:
reader = csv.DictReader(fh)
with conn.cursor() as c:
@@ -45,7 +45,7 @@ def download_marks(conn, workdate, payload):
@with_connection
def update_facility(conn, workdate, payload):
#we update the missing facility loanxids
- sqlstring = "SELECT loanxid FROM markit_prices2 EXCEPT SELECT loanxid FROM markit_facility";
+ sqlstring = "SELECT loanxid FROM markit_prices EXCEPT SELECT loanxid FROM markit_facility";
facility_diff_filename = os.path.join(root, "data", "Facility files",
"facility_diff_{0}.csv".format(workdate))
with open( facility_diff_filename, "wb") as fh: