Edit Oasis DAG error

HyejiYu · Sep 27, 2024 · 315ec7f · 315ec7f
1 parent f947dcc
commit 315ec7f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/Oasis_dag.py b/airflow/Oasis_dag.py
@@ -66,7 +66,7 @@ def generate_queue_values():
     # BashOperator에서 expand로 받은 값을 사용
     run_consumer_task = BashOperator.partial(
         task_id="run-consumer-task",
-        bash_command="python3 /home/patturning1/homeplus_consumer.py {{ params.consumer }}",  # 템플릿을 사용하여 매핑된 값 사용
+        bash_command="python3 /home/patturning1/oasis_consumer.py {{ params.consumer }}",  # 템플릿을 사용하여 매핑된 값 사용
     ).expand(params=generate_queue_values())
 
     [