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

add cron job borrowed_share

Browse Source
This commit is contained in:
MuslemRahimi 2024-07-01 15:22:05 +02:00
parent 017082d212
commit 1dea1393fa
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/primary_cron_job.py
View File

@ -353,6 +353,15 @@ def run_fda_calendar():
] ]
subprocess.run(command) subprocess.run(command)
def run_borrowed_share():
subprocess.run(["python3", "cron_borrowed_share.py"])
command = [
"sudo", "rsync", "-avz", "-e", "ssh",
"/root/backend/app/json/borrowed-share",
f"root@{useast_ip_address}:/root/backend/app/json"
]
subprocess.run(command)
# Create functions to run each schedule in a separate thread # Create functions to run each schedule in a separate thread
def run_threaded(job_func): def run_threaded(job_func):
job_thread = threading.Thread(target=job_func) job_thread = threading.Thread(target=job_func)
@ -384,6 +393,7 @@ schedule.every().day.at("14:00").do(run_threaded, run_cron_var).tag('var_job')
schedule.every().day.at("15:45").do(run_threaded, run_restart_cache) schedule.every().day.at("15:45").do(run_threaded, run_restart_cache)
schedule.every(2).days.at("01:00").do(run_borrowed_share).tag('borrowed_share_job')
schedule.every().saturday.at("01:00").do(run_threaded, run_market_maker).tag('markt_maker_job') schedule.every().saturday.at("01:00").do(run_threaded, run_market_maker).tag('markt_maker_job')
schedule.every().saturday.at("05:00").do(run_threaded, run_ownership_stats).tag('ownership_stats_job') schedule.every().saturday.at("05:00").do(run_threaded, run_ownership_stats).tag('ownership_stats_job')