diff --git a/airflow/HomePlus_dag.py b/airflow/HomePlus_dag.py index 41e3e9c..f1f0997 100644 --- a/airflow/HomePlus_dag.py +++ b/airflow/HomePlus_dag.py @@ -111,4 +111,4 @@ def collect_task_results(**context): send_post_request_HOMEPLUS_task.expand(category_id=category_ids), ] >> collect_task_results_task >> send_summary_email -##### +#######