From 263a001ffb99b271b65bb36db851fec802a91d2a Mon Sep 17 00:00:00 2001 From: MuslemRahimi Date: Thu, 12 Sep 2024 15:55:31 +0200 Subject: [PATCH] update --- app/cron_options_flow.py | 4 ++-- app/primary_cron_job.py | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/app/cron_options_flow.py b/app/cron_options_flow.py index 3778edd..3d39090 100755 --- a/app/cron_options_flow.py +++ b/app/cron_options_flow.py @@ -57,9 +57,9 @@ def process_page(page): item['strike_price'] = round(float(item['strike_price']), 2) item['cost_basis'] = round(float(item['cost_basis']), 2) item['underlying_price'] = round(float(item['underlying_price']), 2) - item['type'] = item['option_activity_type'].capitalize() + item['option_activity_type'] = item['option_activity_type'].capitalize() item['sentiment'] = item['sentiment'].capitalize() - item['executionEstimate'] = item['execution_estimate'].replace('_', ' ').title() + item['execution_estimate'] = item['execution_estimate'].replace('_', ' ').title() item['tradeCount'] = item['trade_count'] page_list.append(item) diff --git a/app/primary_cron_job.py b/app/primary_cron_job.py index e9c84f7..9aa76bb 100755 --- a/app/primary_cron_job.py +++ b/app/primary_cron_job.py @@ -644,11 +644,12 @@ schedule.every(6).hours.do(run_threaded, run_json).tag('json_job') schedule.every(12).hours.do(run_threaded, run_analyst_rating).tag('analyst_job') -schedule.every(20).seconds.do(run_threaded, run_if_not_running(run_cron_options_flow, 'options_flow_job')).tag('options_flow_job') schedule.every(60).seconds.do(run_threaded, run_if_not_running(run_cron_options_zero_dte, 'options_zero_dte_job')).tag('options_zero_dte_job') schedule.every(2).minutes.do(run_threaded, run_dashboard).tag('dashboard_job') +schedule.every(20).seconds.do(run_threaded, run_if_not_running(run_cron_options_flow, 'options_flow_job')).tag('options_flow_job') + # Run the scheduled jobs indefinitelyp while True: