From 23f8f3c6bf0292f8fab2e67ecd825d51d5455ce9 Mon Sep 17 00:00:00 2001 From: MuslemRahimi Date: Mon, 15 Jul 2024 15:26:35 +0200 Subject: [PATCH] update cron job --- app/cron_market_maker.py | 2 +- app/primary_cron_job.py | 14 ++++++-------- 2 files changed, 7 insertions(+), 9 deletions(-) diff --git a/app/cron_market_maker.py b/app/cron_market_maker.py index 5f3e953..1da8c51 100644 --- a/app/cron_market_maker.py +++ b/app/cron_market_maker.py @@ -107,7 +107,7 @@ async def run(): con.close() etf_con.close() - total_symbols = stocks_symbols + etf_symbols + total_symbols = stocks_symbols #+ etf_symbols async with aiohttp.ClientSession() as session: tasks = [process_ticker(ticker) for ticker in total_symbols] diff --git a/app/primary_cron_job.py b/app/primary_cron_job.py index bbb3aa2..b47e8de 100755 --- a/app/primary_cron_job.py +++ b/app/primary_cron_job.py @@ -289,13 +289,11 @@ def run_options_bubble_ticker(): run_command(command) def run_analyst_rating(): - week = datetime.today().weekday() - if week <= 5: - run_command(["python3", "cron_analyst_db.py"]) - run_command(["python3", "cron_analyst_ticker.py"]) - run_command(["python3", "cron_analyst_insight.py"]) - command = ["sudo", "rsync", "-avz", "-e", "ssh", "/root/backend/app/json/analyst", f"root@{useast_ip_address}:/root/backend/app/json"] - run_command(command) + run_command(["python3", "cron_analyst_insight.py"]) + run_command(["python3", "cron_analyst_db.py"]) + run_command(["python3", "cron_analyst_ticker.py"]) + command = ["sudo", "rsync", "-avz", "-e", "ssh", "/root/backend/app/json/analyst", f"root@{useast_ip_address}:/root/backend/app/json"] + run_command(command) def run_market_moods(): week = datetime.today().weekday() @@ -479,7 +477,7 @@ schedule.every(10).minutes.do(run_threaded, run_dark_pool_flow).tag('dark_pool_f 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(12).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_cron_options_zero_dte).tag('options_zero_dte_job')