[fix] hotfix DAG scheduling time fix

zizzic · Mar 4, 2024 · 4c418d8 · 4c418d8
1 parent 4cf5d0a
commit 4c418d8
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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: