diff --git a/orchestration/dags/jobs/administration/bigquery_archive_partition.py b/orchestration/dags/jobs/administration/bigquery_archive_partition.py index 89fd556a74..016aedda67 100644 --- a/orchestration/dags/jobs/administration/bigquery_archive_partition.py +++ b/orchestration/dags/jobs/administration/bigquery_archive_partition.py @@ -11,6 +11,7 @@ SSHGCEOperator, StartGCEOperator, ) +from jobs.crons import SCHEDULE_DICT from airflow import DAG from airflow.models import Param @@ -44,7 +45,7 @@ dag = DAG( DAG_NAME, default_args=dag_config, - schedule_interval="@daily", # Runs daily + schedule_interval=SCHEDULE_DICT[DAG_NAME], # Runs daily catchup=False, params={ "branch": Param( diff --git a/orchestration/dags/jobs/crons.py b/orchestration/dags/jobs/crons.py index fce199a3fd..835d3cc9e9 100644 --- a/orchestration/dags/jobs/crons.py +++ b/orchestration/dags/jobs/crons.py @@ -4,6 +4,7 @@ "dev": "0 12 * * 2", "stg": "0 12 * * 3", }, + "bigquery_export_old_partitions": "0 7 * * *", "clickhouse_exports": { "daily": { "prod": "0 6 * * *",