diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/api_quotes/__main__.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/api_quotes/__main__.py b/python/api_quotes/__main__.py index 35ed2172..59597e39 100644 --- a/python/api_quotes/__main__.py +++ b/python/api_quotes/__main__.py @@ -16,11 +16,11 @@ logger = logging.getLogger(__name__) def process_asset_class(asset_class, start_from, end): already_uploaded = MarkitQuoteKind[asset_class].already_uploaded() while True: - if end and (start_from < end): - break try: if data := MarkitAPI.get_data(asset_class, start_from): for (quoteid, receiveddatetime), quotes in data: + if end and (receiveddatetime < end): + break quotes = list(quotes) # Don't try to insert into DB if already uploaded if quoteid in already_uploaded: |