bugfixing paging request of dark pool api

stocknear · Jul 10, 2024 · e05df54 · e05df54
1 parent cf7ca97
commit e05df54
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git 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
@@ -477,7 +477,7 @@ def run_threaded(job_func):
 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')