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-18 10:46:02 +01:00
parent ebc102faf4
commit e9d9997719
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
app/primary_cron_job.py
View File

@ -222,12 +222,10 @@ def run_historical_price():
run_command(["python3", "cron_historical_price.py"]) run_command(["python3", "cron_historical_price.py"])
def run_one_day_price(): def run_one_day_price():
from utils.helper import check_market_hours now = datetime.now(ny_tz)
week = now.weekday()
week = datetime.today().weekday() hour = now.hour
market_open = check_market_hours() if week <= 4 and 9 <= hour < 17:
if week <= 4 and market_open:
run_command(["python3", "cron_one_day_price.py"]) run_command(["python3", "cron_one_day_price.py"])
def run_sec_filings(): def run_sec_filings():
@ -366,7 +364,7 @@ def run_threaded(job_func):
# Schedule the job to run # Schedule the job to run
schedule.every().day.at("01:00").do(run_threaded, run_options_jobs).tag('options_job') schedule.every().day.at("02:00").do(run_threaded, run_options_jobs).tag('options_job')
schedule.every().day.at("01:00").do(run_threaded, run_db_schedule_job) schedule.every().day.at("01:00").do(run_threaded, run_db_schedule_job)
schedule.every().day.at("05:00").do(run_threaded, run_options_historical_flow).tag('options_historical_flow_job') schedule.every().day.at("05:00").do(run_threaded, run_options_historical_flow).tag('options_historical_flow_job')