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 2024-12-26 15:45:41 +01:00
parent 2467056255
commit 24409f0009
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
app/primary_cron_job.py
View File

@ -57,6 +57,15 @@ def run_command(command):
logger.error("Error:\n" + stderr)
'''
def run_dark_pool_flow():
week = datetime.today().weekday()
if week <= 4:
run_command(["python3", "cron_dark_pool_flow.py"])
def run_fda_calendar():
week = datetime.today().weekday()
if week <= 4:
run_command(["python3", "cron_fda_calendar.py"])
def run_cron_insider_trading():
week = datetime.today().weekday()
@ -368,11 +377,15 @@ schedule.every(2).hours.do(run_threaded, run_analyst_rating).tag('analyst_job')
schedule.every(1).hours.do(run_threaded, run_company_news).tag('company_news_job')
schedule.every(3).hours.do(run_threaded, run_press_releases).tag('press_release_job')
schedule.every(1).hours.do(run_threaded, run_fda_calendar).tag('fda_calendar_job')
schedule.every(1).minutes.do(run_threaded, run_dark_pool_flow).tag('dark_pool_flow_job')
schedule.every(2).minutes.do(run_threaded, run_dashboard).tag('dashboard_job')
schedule.every(10).seconds.do(run_threaded, run_if_not_running(run_cron_options_flow, 'options_flow_job')).tag('options_flow_job')