From e56c0eb23ed5c2fea271507877d83b3595ec4732 Mon Sep 17 00:00:00 2001 From: MuslemRahimi Date: Wed, 8 Jan 2025 10:04:03 +0100 Subject: [PATCH] fix cron job --- app/cron_options_gex_dex.py | 5 ++++- app/primary_cron_job.py | 4 +++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/app/cron_options_gex_dex.py b/app/cron_options_gex_dex.py index 587be8d..688bdaf 100644 --- a/app/cron_options_gex_dex.py +++ b/app/cron_options_gex_dex.py @@ -85,6 +85,7 @@ def prepare_data(data, symbol, directory_path, sort_by = "date"): def get_overview_data(): + print("Starting to download overview data...") directory_path = "json/gex-dex/overview" total_symbols = get_tickers_from_directory(directory_path) if len(total_symbols) < 100: @@ -115,6 +116,7 @@ def get_overview_data(): def get_strike_data(): + print("Starting to download strike data...") directory_path = "json/gex-dex/strike" total_symbols = get_tickers_from_directory(directory_path) if len(total_symbols) < 100: @@ -143,6 +145,7 @@ def get_strike_data(): print(f"Error for {symbol}:{e}") def get_expiry_data(): + print("Starting to download expiry data...") directory_path = "json/gex-dex/expiry" total_symbols = get_tickers_from_directory(directory_path) if len(total_symbols) < 100: @@ -172,7 +175,7 @@ def get_expiry_data(): if __name__ == '__main__': - #get_overview_data() + get_overview_data() get_strike_data() get_expiry_data() diff --git a/app/primary_cron_job.py b/app/primary_cron_job.py index 3543600..554e5f8 100755 --- a/app/primary_cron_job.py +++ b/app/primary_cron_job.py @@ -68,7 +68,9 @@ def run_dark_pool_flow(): def run_market_flow(): now = datetime.now(ny_tz) week = now.weekday() - if week <= 4: + current_time = now.time() + hour = now.hour + if week <= 4 and 9 < hour < 20: run_command(["python3", "cron_market_flow.py"]) def run_dark_pool_level():