From e05df545d8402e0ec1129e6a644477d62f7e2459 Mon Sep 17 00:00:00 2001 From: MuslemRahimi Date: Wed, 10 Jul 2024 16:53:48 +0200 Subject: [PATCH] bugfixing paging request of dark pool api --- app/cron_dark_pool_flow.py | 6 ++++-- app/primary_cron_job.py | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/app/cron_dark_pool_flow.py b/app/cron_dark_pool_flow.py index fb08509..93038e1 100644 --- a/app/cron_dark_pool_flow.py +++ b/app/cron_dark_pool_flow.py @@ -22,7 +22,9 @@ def save_json(data): source = 'cta_a_delayed' -start_date, end_date = GetStartEndDate().run() +#start_date, end_date = GetStartEndDate().run() +start_date = '' +end_date = '' start_time = '' end_time = '' timezone = 'UTC' @@ -80,7 +82,7 @@ def run(): { 'symbol': entry['_symbol'], 'name': symbol_name_map[entry['_symbol']], - 'date': (entry['_timestamp']).isoformat(), + 'date': (entry['_timestamp']-timedelta(hours=4)).isoformat(), 'price': entry['_price'], 'volume': entry['_total_volume'], 'size': entry['_size'] diff --git a/app/primary_cron_job.py b/app/primary_cron_job.py index e5b03b5..c60b49e 100755 --- a/app/primary_cron_job.py +++ b/app/primary_cron_job.py @@ -477,7 +477,7 @@ schedule.every(15).minutes.do(run_threaded, run_cron_heatmap).tag('heatmap_job') schedule.every(1).minutes.do(run_threaded, run_cron_quote).tag('quote_job') schedule.every(1).minutes.do(run_threaded, run_cron_price_alert).tag('price_alert_job') schedule.every(15).minutes.do(run_threaded, run_market_moods).tag('market_moods_job') -#schedule.every(20).minutes.do(run_threaded, run_dark_pool_flow).tag('dark_pool_flow_job') +schedule.every(10).minutes.do(run_threaded, run_dark_pool_flow).tag('dark_pool_flow_job') schedule.every(2).hours.do(run_threaded, run_fda_calendar).tag('fda_calendar_job') schedule.every(3).hours.do(run_threaded, run_json_job).tag('json_job')