From 1358c72cd91683f40258afd7ad1e949dca1c0df9 Mon Sep 17 00:00:00 2001 From: MuslemRahimi Date: Fri, 4 Oct 2024 14:30:24 +0200 Subject: [PATCH] update cron job --- app/primary_cron_job.py | 11 ----------- app/secondary_cron_job.py | 11 ++++++++--- 2 files changed, 8 insertions(+), 14 deletions(-) diff --git a/app/primary_cron_job.py b/app/primary_cron_job.py index e8f12ce..f921418 100755 --- a/app/primary_cron_job.py +++ b/app/primary_cron_job.py @@ -236,16 +236,6 @@ def run_ta_rating(): ] run_command(command) -def run_stockdeck(): - week = datetime.today().weekday() - if week <= 5: - run_command(["python3", "cron_stockdeck.py"]) - command = [ - "sudo", "rsync", "-avz", "-e", "ssh", - "/root/backend/app/json/stockdeck", - f"root@{useast_ip_address}:/root/backend/app/json" - ] - run_command(command) def run_similar_stocks(): week = datetime.today().weekday() @@ -637,7 +627,6 @@ schedule.every().day.at("12:00").do(run_threaded, run_market_cap).tag('market_ca #schedule.every().day.at("05:00").do(run_threaded, run_implied_volatility).tag('implied_volatility_job') -schedule.every().day.at("13:30").do(run_threaded, run_stockdeck).tag('stockdeck_job') schedule.every().day.at("13:40").do(run_threaded, run_analyst_estimate).tag('analyst_estimate_job') schedule.every().day.at("13:45").do(run_threaded, run_similar_stocks).tag('similar_stocks_job') schedule.every().day.at("14:00").do(run_threaded, run_cron_var).tag('var_job') diff --git a/app/secondary_cron_job.py b/app/secondary_cron_job.py index 4d6abbc..8ebd7f8 100755 --- a/app/secondary_cron_job.py +++ b/app/secondary_cron_job.py @@ -24,7 +24,7 @@ subprocess.run(["timedatectl", "set-timezone", "Europe/Berlin"]) def run_pocketbase(): # Run the asynchronous function inside an asyncio loop - run_command(["python3", "cron_pocketbase.py"]) + subprocess(["python3", "cron_pocketbase.py"]) def run_restart_cache(): #update db daily @@ -33,7 +33,11 @@ def run_restart_cache(): subprocess.run(["pm2", "restart","fastapi"]) subprocess.run(["pm2", "restart","fastify"]) - +def run_stockdeck(): + week = datetime.today().weekday() + if week <= 5: + subprocess(["python3", "cron_stockdeck.py"]) + def run_json_job(): # Run the asynchronous function inside an asyncio loop subprocess.run(["python3", "restart_json.py"]) @@ -43,7 +47,7 @@ def run_json_job(): def run_cron_price_alert(): week = datetime.today().weekday() if week <= 4: - run_command(["python3", "cron_price_alert.py"]) + subprocess(["python3", "cron_price_alert.py"]) # Create functions to run each schedule in a separate thread def run_threaded(job_func): @@ -52,6 +56,7 @@ def run_threaded(job_func): schedule.every().day.at("06:30").do(run_threaded, run_pocketbase).tag('pocketbase_job') +schedule.every().day.at("13:30").do(run_threaded, run_stockdeck).tag('stockdeck_job') schedule.every().day.at("15:45").do(run_threaded, run_restart_cache) schedule.every(2).hours.do(run_threaded, run_json_job).tag('json_job') schedule.every(1).minutes.do(run_threaded, run_cron_price_alert).tag('price_alert_job')