diff options
| -rw-r--r-- | python/markit/import_quotes.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/python/markit/import_quotes.py b/python/markit/import_quotes.py index d32fdf6c..bb53fb03 100644 --- a/python/markit/import_quotes.py +++ b/python/markit/import_quotes.py @@ -20,8 +20,9 @@ def convert(x): def get_index_list(database, workdate): with database.cursor() as c: c.execute("SELECT distinct index, series FROM index_maturity " - "WHERE issue_date IS NOT NULL and issue_date <= %s + 10", - (workdate,)) + "WHERE issue_date IS NOT NULL and issue_date <= %s + 10 " + "AND maturity >= %s", + (workdate, workdate)) for index, series in c: yield index + str(series) database.commit() |