Skip to content

Commit 0b17f3f

Browse files
authored
Merge pull request #105 from zizzic/develop_fix_for_youngho
[feat] set Catchup&Startdate for game Glue DAG
2 parents a4fa495 + 95ef84a commit 0b17f3f

File tree

3 files changed

+9
-6
lines changed

3 files changed

+9
-6
lines changed

dags/glue/game_ccu.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,12 +37,13 @@ def upload_rendered_script_to_s3(
3737
"owner": "airflow",
3838
"depends_on_past": False,
3939
"start_date": datetime(2024, 2, 22),
40-
"retries": 0,
40+
"retries": 3,
4141
"retry_delay": timedelta(minutes=5),
4242
},
43+
max_active_runs=1,
4344
schedule_interval="5 * * * *",
4445
tags=["glue", "Game_CCU"],
45-
catchup=False,
46+
catchup=True,
4647
) as dag:
4748

4849
bucket_name = "de-2-1-bucket"

dags/glue/game_price.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,12 +37,13 @@ def upload_rendered_script_to_s3(
3737
"owner": "airflow",
3838
"depends_on_past": False,
3939
"start_date": datetime(2024, 2, 22),
40-
"retries": 0,
40+
"retries": 3,
4141
"retry_delay": timedelta(minutes=5),
4242
},
43+
max_active_runs=1,
4344
schedule_interval="0 1 * * *",
4445
tags=["glue", "Game_Price"],
45-
catchup=False,
46+
catchup=True,
4647
) as dag:
4748

4849
bucket_name = "de-2-1-bucket"

dags/glue/game_rating.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,12 +37,13 @@ def upload_rendered_script_to_s3(
3737
"owner": "airflow",
3838
"depends_on_past": False,
3939
"start_date": datetime(2024, 2, 22),
40-
"retries": 0,
40+
"retries": 3,
4141
"retry_delay": timedelta(minutes=5),
4242
},
43+
max_active_runs=1,
4344
schedule_interval="0 1 * * *",
4445
tags=["glue", "Game_Rating"],
45-
catchup=False,
46+
catchup=True,
4647
) as dag:
4748

4849
bucket_name = "de-2-1-bucket"

0 commit comments

Comments
 (0)