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

update cron job

Browse Source
This commit is contained in:
MuslemRahimi 2025-01-12 16:40:48 +01:00
parent 75241ba448
commit 574c2b1413
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
app/primary_cron_job.py
View File

@ -288,11 +288,17 @@ def run_tracker():
#"cron_lobbying_tracker.py", #"cron_lobbying_tracker.py",
#"cron_sentiment_tracker.py", #"cron_sentiment_tracker.py",
"cron_insider_tracker.py", "cron_insider_tracker.py",
"cron_list.py",
] ]
for script in scripts: for script in scripts:
run_command(["python3", script]) run_command(["python3", script])
def run_list():
week = datetime.today().weekday()
if week <= 5:
run_command(["python3", "cron_list.py"])
def run_financial_statements(): def run_financial_statements():
week = datetime.today().weekday() week = datetime.today().weekday()
if week <= 4: if week <= 4:
@ -402,6 +408,10 @@ schedule.every(3).hours.do(run_threaded, run_press_releases).tag('press_release_
schedule.every(1).hours.do(run_threaded, run_fda_calendar).tag('fda_calendar_job') schedule.every(1).hours.do(run_threaded, run_fda_calendar).tag('fda_calendar_job')
schedule.every(5).minutes.do(run_threaded, run_market_flow).tag('market_flow_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')
schedule.every(30).minutes.do(run_threaded, run_dark_pool_level).tag('dark_pool_level_job') schedule.every(30).minutes.do(run_threaded, run_dark_pool_level).tag('dark_pool_level_job')
schedule.every(10).seconds.do(run_threaded, run_dark_pool_flow).tag('dark_pool_flow_job') schedule.every(10).seconds.do(run_threaded, run_dark_pool_flow).tag('dark_pool_flow_job')