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

schedule options flow correctly

Browse Source
This commit is contained in:
MuslemRahimi 2024-08-15 18:24:17 +02:00
parent ca820c9336
commit bbcabce052
1 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
app/primary_cron_job.py
View File

@ -12,6 +12,12 @@ from dotenv import load_dotenv
import os import os
load_dotenv() load_dotenv()
# Create a dictionary to store the status of each job
job_status = {
'options_flow_job': {'running': False},
'options_zero_dte_job': {'running': False}
}
useast_ip_address = os.getenv('USEAST_IP_ADDRESS') useast_ip_address = os.getenv('USEAST_IP_ADDRESS')
@ -30,6 +36,16 @@ logger.addHandler(handler)
subprocess.run(["timedatectl", "set-timezone", "Europe/Berlin"]) subprocess.run(["timedatectl", "set-timezone", "Europe/Berlin"])
def run_if_not_running(job_func, job_tag):
def wrapper():
if not job_status[job_tag]['running']:
job_status[job_tag]['running'] = True
try:
job_func()
finally:
job_status[job_tag]['running'] = False
return wrapper
# Function to run commands and log output # Function to run commands and log output
def run_command(command): def run_command(command):
process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True) process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
@ -194,7 +210,7 @@ def run_cron_options_flow():
end_time = datetime_time(22, 30) end_time = datetime_time(22, 30)
if week <= 4 and start_time <= current_time < end_time: if week <= 4 and start_time <= current_time < end_time:
run_command(["python3", "cron_options_flow.py"]) run_command(["python3", "cron_options_flow.py"])
command = [ command = [
"sudo", "rsync", "-avz", "-e", "ssh", "sudo", "rsync", "-avz", "-e", "ssh",
@ -542,8 +558,8 @@ 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')
schedule.every(6).hours.do(run_threaded, run_analyst_rating).tag('analyst_job') schedule.every(6).hours.do(run_threaded, run_analyst_rating).tag('analyst_job')
schedule.every(10).seconds.do(run_threaded, run_cron_options_flow).tag('options_flow_job') schedule.every(10).seconds.do(run_threaded, run_if_not_running(run_cron_options_flow, 'options_flow_job')).tag('options_flow_job')
schedule.every(10).seconds.do(run_threaded, run_cron_options_zero_dte).tag('options_zero_dte_job') schedule.every(10).seconds.do(run_threaded, run_if_not_running(run_cron_options_zero_dte, 'options_zero_dte_job')).tag('options_zero_dte_job')
# Run the scheduled jobs indefinitelyp # Run the scheduled jobs indefinitelyp