Skip to content

Commit

Permalink
Update fetch_eform_notices_by_date.py
Browse files Browse the repository at this point in the history
  • Loading branch information
CaptainOfHacks committed Feb 23, 2024
1 parent 6b2dc7f commit 54594bc
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions dags/eforms_notices/fetch_eform_notices_by_date.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
from airflow import AirflowException
from airflow.decorators import dag, task
from pymongo import MongoClient

Expand Down Expand Up @@ -44,6 +45,7 @@ def fetch_by_date_notice_from_ted():
notice_ids = notice_fetcher_by_query_pipeline(query=query)
if not notice_ids:
log_error("No notices has been fetched!")
raise AirflowException("No notices has been")
else:
push_dag_downstream(key=NOTICE_IDS_KEY, value=notice_ids)

Expand Down

0 comments on commit 54594bc

Please sign in to comment.