diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/facility_download.py | 2 | ||||
| -rw-r--r-- | python/markit_loans.py | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/python/facility_download.py b/python/facility_download.py index 141f6e4f..58a0603c 100644 --- a/python/facility_download.py +++ b/python/facility_download.py @@ -24,7 +24,7 @@ flag = False # flag = True
-sqlstring = "select loanxid from markit_prices2 except (select loanxid from latest_markit_prices2)"
+sqlstring = "select loanxid from markit_prices except (select loanxid from latest_markit_prices2)"
loan_ids = query_db(sqlstring, one=False)
with open( os.path.join(root, "data", "Facility files",
"facility_test.csv"), "wb") as fh:
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:
|