modified DAG file

HyejiYu · Sep 23, 2024 · 4e1f75c · 4e1f75c
1 parent 7a377db
commit 4e1f75c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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.param1 }}",  # 템플릿을 사용하여 매핑된 값 사용
+        bash_command="python3 /home/patturning1/consumer_mq.py {{ params.consumer }}",  # 템플릿을 사용하여 매핑된 값 사용
     ).expand(params=generate_queue_values())
 
     category_ids = list(range(100001, 100078))