From b9ebc5c1485cd0de757880f9a85f5f8c567961f1 Mon Sep 17 00:00:00 2001 From: charlielewisme Date: Fri, 26 Jan 2024 20:50:14 +0000 Subject: [PATCH] temporarily set catchup = True --- airflow/dags/polygonetl_airflow/build_parse_dag.py | 2 +- airflow/dags/polygonetl_airflow/build_partition_dag.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/dags/polygonetl_airflow/build_parse_dag.py b/airflow/dags/polygonetl_airflow/build_parse_dag.py index 7c42ec5..bcd47e9 100644 --- a/airflow/dags/polygonetl_airflow/build_parse_dag.py +++ b/airflow/dags/polygonetl_airflow/build_parse_dag.py @@ -57,7 +57,7 @@ def build_parse_dag( dag = models.DAG( dag_id, - catchup=False, + catchup=True, schedule=parse_schedule, default_args=default_dag_args) diff --git a/airflow/dags/polygonetl_airflow/build_partition_dag.py b/airflow/dags/polygonetl_airflow/build_partition_dag.py index bd5c75b..e84bb87 100644 --- a/airflow/dags/polygonetl_airflow/build_partition_dag.py +++ b/airflow/dags/polygonetl_airflow/build_partition_dag.py @@ -43,7 +43,7 @@ def build_partition_dag( # Define a DAG (directed acyclic graph) of tasks. dag = models.DAG( dag_id, - catchup=False, + catchup=True, schedule=partition_schedule, default_args=default_dag_args)