Skip to content

Commit

Permalink
Update daily_notices_metadata_update.py
Browse files Browse the repository at this point in the history
  • Loading branch information
duprijil committed Oct 6, 2023
1 parent b67146b commit 2733359
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions dags/daily_notices_metadata_update.py
Original file line number Diff line number Diff line change
Expand Up @@ -49,8 +49,8 @@
def daily_notices_metadata_update():
@task
def update_daily_notices_metadata_from_ted_api():
start_date = get_dag_param(key=START_DATE_PARAM_KEY, raise_error=False)
end_date = get_dag_param(key=END_DATE_PARAM_KEY, raise_error=False)
start_date = get_dag_param(key=START_DATE_PARAM_KEY)
end_date = get_dag_param(key=END_DATE_PARAM_KEY)

if start_date and end_date:
start_date = datetime.strptime(start_date, "%Y-%m-%d")
Expand All @@ -63,8 +63,8 @@ def update_daily_notices_metadata_from_ted_api():

@task
def update_daily_notices_metadata_with_fetched_data_from_repo():
start_date = get_dag_param(key=START_DATE_PARAM_KEY, raise_error=False)
end_date = get_dag_param(key=END_DATE_PARAM_KEY, raise_error=False)
start_date = get_dag_param(key=START_DATE_PARAM_KEY)
end_date = get_dag_param(key=END_DATE_PARAM_KEY)

if start_date and end_date:
start_date = datetime.strptime(start_date, "%Y-%m-%d")
Expand Down

0 comments on commit 2733359

Please sign in to comment.