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))