Merge pull request #397 from OP-TED/feature/TED-1047

Update notice_fetch_by_date_workflow.py

Author: CaptainOfHacks

dags/notice_fetch_by_date_workflow.py

@@ -1,3 +1,5 @@
+from datetime import timedelta
+
 from airflow.decorators import dag, task
 from airflow.operators.dummy import DummyOperator
 from airflow.operators.python import BranchPythonOperator, PythonOperator
@@ -58,7 +60,9 @@ def validate_fetched_notices():
         from datetime import datetime
         from pymongo import MongoClient
 
-        publication_date = datetime.strptime(get_dag_param(key=WILD_CARD_DAG_KEY), "%Y%m%d*")
+        publication_date = datetime.strptime(get_dag_param(key=WILD_CARD_DAG_KEY,
+                                                           default_value=(datetime.now() - timedelta(days=1)).strftime(
+                                                               "%Y%m%d*")), "%Y%m%d*")
         mongodb_client = MongoClient(config.MONGO_DB_AUTH_URL)
         validate_and_update_daily_supra_notice(notice_publication_day=publication_date,
                                                mongodb_client=mongodb_client)

tests/features/notice_publisher/test_notice_publisher_s3.py

@@ -48,6 +48,7 @@ def the_notice_mets_manifestation_publication_is_executed(publish_eligible_notic
     publish_result = publish_notice_into_s3(notice=publish_eligible_notice, s3_publisher=s3_publisher,
                                             bucket_name=s3_bucket_name)
     assert publish_result
+    publish_eligible_notice.update_status_to(new_status=NoticeStatus.PUBLISHED)
     return publish_eligible_notice