fixed DAG dependencies

HyejiYu · Sep 27, 2024 · 71b62c5 · 71b62c5
1 parent d822719
commit 71b62c5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/HomePlus_dag.py b/airflow/HomePlus_dag.py
@@ -81,7 +81,7 @@ def generate_queue_values():
     category_ids = list(range(100001, 100078))
 
     # 모든 병렬 태스크가 완료된 후의 마무리 태스크
-    final_task = EmptyOperator(
+    empty_task = EmptyOperator(
         task_id='empty-task',
         dag=dag
     )
@@ -114,4 +114,4 @@ def generate_queue_values():
     [
         run_consumer_task,
         send_post_request_HOMEPLUS_task.expand(category_id=category_ids),
-    ] >> [send_failure_email, send_success_email]
+    ] >> empty_task >> [send_failure_email, send_success_email]