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

update primary job

Browse Source
This commit is contained in:
MuslemRahimi 2025-02-05 15:01:29 +01:00
parent 2591edd802
commit d859e0fd97
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/primary_cron_job.py
View File

@ -73,11 +73,12 @@ def run_market_flow():
if week <= 4 and 8 <= hour < 20:
run_command(["python3", "cron_market_flow.py"])
def run_unusual_activity():
def run_options_stats():
now = datetime.now(ny_tz)
week = now.weekday()
hour = now.hour
if week <= 4 and 9 <= hour <= 16:
if week <= 4 and 9 <= hour <= 17:
run_command(["python3", "cron_option_stats.py"])
run_command(["python3", "cron_unusual_activity.py"])
def run_dark_pool_level():
@ -102,7 +103,6 @@ def run_options_jobs():
run_command(["python3", "cron_options_historical_volume.py"])
run_command(["python3", "cron_options_hottest_contracts.py"])
run_command(["python3", "cron_implied_volatility.py"])
run_command(["python3", "cron_options_stats.py"])
run_command(["python3", "cron_options_oi.py"])
'''
run_command(["python3", "cron_options_gex_dex.py"])
@ -422,7 +422,7 @@ schedule.every(3).hours.do(run_threaded, run_press_releases).tag('press_release_
schedule.every(5).minutes.do(run_threaded, run_push_notifications).tag('push_notifications_job')
schedule.every(10).minutes.do(run_threaded, run_unusual_activity).tag('unusual_activity_job')
schedule.every(10).minutes.do(run_threaded, run_options_stats).tag('options_stats_job')
schedule.every(5).minutes.do(run_threaded, run_market_flow).tag('market_flow_job')
schedule.every(5).minutes.do(run_threaded, run_list).tag('stock_list_job')