From 59408300385b51a6ea7eab71ef7d14b24751e8b3 Mon Sep 17 00:00:00 2001 From: hyejiyu Date: Tue, 24 Sep 2024 00:42:40 +0900 Subject: [PATCH] modified DAG file --- airflow/dag.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/dag.py b/airflow/dag.py index d635138..9e59793 100644 --- a/airflow/dag.py +++ b/airflow/dag.py @@ -82,7 +82,7 @@ def generate_queue_values(): # BashOperator에서 expand로 받은 값을 사용 run_consumer_task = BashOperator.partial( task_id="run-consumer-task", - bash_command="python3 /home/patturning1/consumer_mq.py {{ params.consumer }}", # 템플릿을 사용하여 매핑된 값 사용 + bash_command="python3 /home/patturning1/homeplus_consumer.py {{ params.consumer }}", # 템플릿을 사용하여 매핑된 값 사용 ).expand(params=generate_queue_values()) category_ids = list(range(100001, 100078))