From 4c418d86ceee49fc5bab26f8cf63ee5e9a4ebf76 Mon Sep 17 00:00:00 2001 From: lyh Date: Mon, 4 Mar 2024 21:02:14 +0900 Subject: [PATCH] [fix] hotfix DAG scheduling time fix --- dags/game/game_price_to_s3.py | 2 +- dags/game/game_rating_to_s3.py | 2 +- dags/glue/game_price.py | 2 +- dags/glue/game_rating.py | 2 +- dags/glue/glue_followers.py | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/dags/game/game_price_to_s3.py b/dags/game/game_price_to_s3.py index b682d5c..fe9d918 100644 --- a/dags/game/game_price_to_s3.py +++ b/dags/game/game_price_to_s3.py @@ -100,7 +100,7 @@ def save_to_json(data): start_date=datetime(2024, 1, 1), catchup=False, tags=["Steam_API"], - schedule_interval="0 0 * * *", + schedule_interval="10 15 * * *", default_args={ "retries": 3, "retry_delay": timedelta(seconds=15), diff --git a/dags/game/game_rating_to_s3.py b/dags/game/game_rating_to_s3.py index c134304..0e8abec 100644 --- a/dags/game/game_rating_to_s3.py +++ b/dags/game/game_rating_to_s3.py @@ -126,7 +126,7 @@ def save_to_json(data): start_date=datetime(2024, 1, 1), catchup=False, tags=["Steam_API"], - schedule_interval="0 0 * * *", + schedule_interval="10 15 * * *", default_args={ "retries": 3, "retry_delay": timedelta(minutes=1), diff --git a/dags/glue/game_price.py b/dags/glue/game_price.py index e67a99d..9383eff 100644 --- a/dags/glue/game_price.py +++ b/dags/glue/game_price.py @@ -42,7 +42,7 @@ def upload_rendered_script_to_s3( "retry_delay": timedelta(seconds=15), }, max_active_runs=1, - schedule_interval="0 1 * * *", + schedule_interval="0 16 * * *", tags=["glue", "Game_Price"], catchup=True, ) as dag: diff --git a/dags/glue/game_rating.py b/dags/glue/game_rating.py index a005bbe..d1d91fb 100644 --- a/dags/glue/game_rating.py +++ b/dags/glue/game_rating.py @@ -42,7 +42,7 @@ def upload_rendered_script_to_s3( "retry_delay": timedelta(seconds=15), }, max_active_runs=1, - schedule_interval="0 1 * * *", + schedule_interval="0 16 * * *", tags=["glue", "Game_Rating"], catchup=True, ) as dag: diff --git a/dags/glue/glue_followers.py b/dags/glue/glue_followers.py index 5971720..f15a7ed 100644 --- a/dags/glue/glue_followers.py +++ b/dags/glue/glue_followers.py @@ -43,7 +43,7 @@ def upload_rendered_script_to_s3( }, max_active_runs=1, tags=["glue", "streaming"], - schedule_interval="0 1 * * *", # 한국 기준 오전 10시 + schedule_interval="0 16 * * *", # 한국 기준 오전 10시 catchup=True, ) as dag: