From c37f9022f710670f10953903404388987273d467 Mon Sep 17 00:00:00 2001 From: redstoneenjoyer Date: Wed, 15 Apr 2026 16:32:31 +0300 Subject: [PATCH] unimem dag schedule changed --- dags/stg/union_members/fetch.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/stg/union_members/fetch.py b/dags/stg/union_members/fetch.py index 9b888b7..3d78c57 100644 --- a/dags/stg/union_members/fetch.py +++ b/dags/stg/union_members/fetch.py @@ -231,7 +231,7 @@ def count_all_items(data): with DAG( dag_id="union_member_dwh", - schedule="0 0 */1 * *", + schedule=timedelta(hours=1), start_date=datetime(2023, 1, 1, 2, 0, 0), catchup=False, tags=["stg", "union_member"],