modifed DAG

HyejiYu · Sep 18, 2024 · 9217fa3 · 9217fa3
1 parent ba42a8b
commit 9217fa3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/dag.py b/airflow/dag.py
@@ -50,7 +50,8 @@ def send_post_request(categoryId):
 
     run_consumer_task = BashOperator(
         task_id='run_consumer',       # Task 이름
-        bash_command="python3 /home/patturning1/mq_consumer.py"
+        bash_command="python3 /home/patturning1/mq_consumer.py &",
+        do_xcom_push=False
     )