AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfixing paging request of dark pool api

Browse Source
This commit is contained in:
MuslemRahimi 2024-07-10 16:53:48 +02:00
parent cf7ca97687
commit e05df545d8
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/cron_dark_pool_flow.py
View File

@ -22,7 +22,9 @@ def save_json(data):
source = 'cta_a_delayed' source = 'cta_a_delayed'
start_date, end_date = GetStartEndDate().run() #start_date, end_date = GetStartEndDate().run()
start_date = ''
end_date = ''
start_time = '' start_time = ''
end_time = '' end_time = ''
timezone = 'UTC' timezone = 'UTC'
@ -80,7 +82,7 @@ def run():
{ {
'symbol': entry['_symbol'], 'symbol': entry['_symbol'],
'name': symbol_name_map[entry['_symbol']], 'name': symbol_name_map[entry['_symbol']],
'date': (entry['_timestamp']).isoformat(), 'date': (entry['_timestamp']-timedelta(hours=4)).isoformat(),
'price': entry['_price'], 'price': entry['_price'],
'volume': entry['_total_volume'], 'volume': entry['_total_volume'],
'size': entry['_size'] 'size': entry['_size']

2
app/primary_cron_job.py
View File

@ -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_quote).tag('quote_job')
schedule.every(1).minutes.do(run_threaded, run_cron_price_alert).tag('price_alert_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(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(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') schedule.every(3).hours.do(run_threaded, run_json_job).tag('json_job')