diff --git a/dags/__pycache__/efficiency_auto_simulate.cpython-312.pyc b/dags/__pycache__/efficiency_auto_simulate.cpython-312.pyc index d3fa2a8..4353ab5 100644 Binary files a/dags/__pycache__/efficiency_auto_simulate.cpython-312.pyc and b/dags/__pycache__/efficiency_auto_simulate.cpython-312.pyc differ diff --git a/dags/__pycache__/oh_wo_incremental_data.cpython-312.pyc b/dags/__pycache__/oh_wo_incremental_data.cpython-312.pyc index dea07fe..eeca8e9 100644 Binary files a/dags/__pycache__/oh_wo_incremental_data.cpython-312.pyc and b/dags/__pycache__/oh_wo_incremental_data.cpython-312.pyc differ diff --git a/dags/__pycache__/oh_wo_staging.cpython-312.pyc b/dags/__pycache__/oh_wo_staging.cpython-312.pyc index f87a343..8bacb15 100644 Binary files a/dags/__pycache__/oh_wo_staging.cpython-312.pyc and b/dags/__pycache__/oh_wo_staging.cpython-312.pyc differ diff --git a/dags/efficiency_auto_simulate.py b/dags/efficiency_auto_simulate.py index 49ef887..62666bc 100644 --- a/dags/efficiency_auto_simulate.py +++ b/dags/efficiency_auto_simulate.py @@ -16,7 +16,8 @@ with DAG( 'daily_efficiency_api_calls', default_args=default_args, description='Efficiency API calls at specific times', - schedule_interval='30 0,8,15 * * *', # 07:30, 15:30, 22:30 GMT+7 + # schedule_interval='30 0,8,15 * * *', # 07:30, 15:30, 22:30 GMT+7 + schedule_interval='30 19,3,11 * * *', # 19:30, 03:30, 11:30 UTC start_date=days_ago(1), tags=['api', 'efficiency'], ) as dag: @@ -29,18 +30,3 @@ with DAG( method='GET', ) - # Afternoon call at 15:30 GMT+7 (08:30 UTC) - afternoon_api_call = SimpleHttpOperator( - task_id='afternoon_api_call', - http_conn_id='efficiency_api', - endpoint='efficiency/data/auto', - method='GET', - ) - - # Night call at 22:30 GMT+7 (15:30 UTC) - night_api_call = SimpleHttpOperator( - task_id='night_api_call', - http_conn_id='efficiency_api', - endpoint='efficiency/data/auto', - method='GET', - )