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"],