diff options
Diffstat (limited to 'python/markit_download.py')
| -rw-r--r-- | python/markit_download.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/python/markit_download.py b/python/markit_download.py index 03809eb7..4b34608b 100644 --- a/python/markit_download.py +++ b/python/markit_download.py @@ -36,8 +36,8 @@ common.conn.commit() sqlstring = "INSERT INTO markit_facility VALUES( {0} )".format( ",".join(["%s"] * 13))
with open( facility_filename, "r") as fh:
- reader = csv.reader(fh) # we skip the headers
- reader.next()
+ reader = csv.reader(fh)
+ reader.next() # we skip the headers
for line in reader:
newline = [convertToNone(v) for v in line]
common.cursor.execute(sqlstring, newline)
@@ -47,7 +47,7 @@ common.conn.commit() sqlstring = "SELECT loanxid FROM markit_prices2 EXCEPT SELECT loanxid FROM markit_facility";
common.cursor.execute(sqlstring)
facility_diff_filename = os.path.join(common.root, "data", "Facility files",
- "facility_diff_{0}.csv".format(workdate))
+ "facility_diff_{0}.csv".formfaat(workdate))
with open( facility_diff_filename, "wb") as fh:
flag = False
for loanxid in common.cursor.fetchall():
@@ -65,6 +65,7 @@ sqlstring = "INSERT INTO markit_facility(LoanXID, PMDID, IssuerName, dealname, f if os.path.getsize(facility_diff_filename):
with open(facility_diff_filename, "r") as fh:
reader = csv.reader(fh)
+ reader.next()
for line in reader:
newline = [convertToNone(v) for v in line] + [workdate]
newline.pop(9) # remove the spread to maturity value
|
