From 3e3fcbf2cc6430e91c1ceb2ce7300534f328a8a2 Mon Sep 17 00:00:00 2001 From: Dumitru Date: Fri, 6 Oct 2023 15:56:26 +0300 Subject: [PATCH] Update daily_notices_metadata_update.py --- dags/daily_notices_metadata_update.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/dags/daily_notices_metadata_update.py b/dags/daily_notices_metadata_update.py index f4c42135..86d0ea92 100644 --- a/dags/daily_notices_metadata_update.py +++ b/dags/daily_notices_metadata_update.py @@ -4,12 +4,14 @@ from datetime import date, datetime -from airflow.models import Param from airflow.decorators import dag, task +from airflow.models import Param +from airflow.timetables.trigger import CronTriggerTimetable from dags import DEFAULT_DAG_ARGUMENTS from dags.dags_utils import get_dag_param -from ted_sws.supra_notice_manager.services.daily_notices_metadata_services import update_daily_notices_metadata_from_ted, \ +from ted_sws.supra_notice_manager.services.daily_notices_metadata_services import \ + update_daily_notices_metadata_from_ted, \ update_daily_notices_metadata_with_fetched_data START_DATE_PARAM_KEY = "start_date" @@ -19,6 +21,8 @@ @dag(default_args=DEFAULT_DAG_ARGUMENTS, schedule_interval=None, tags=['daily', "dashboards", "metadata", "ted", "notices"], + catchup=False, + timetable=CronTriggerTimetable('0 19 * * *', timezone='UTC'), description=__doc__[0: __doc__.find(".")], doc_md=__doc__, params={