temporarily set catchup = True

blockchain-etl · Jan 26, 2024 · b9ebc5c · b9ebc5c
1 parent bac563f
commit b9ebc5c
Show file tree

Hide file tree

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