From 9217fa3d780dce25aaf94a1a3b49b320f1d48aaf Mon Sep 17 00:00:00 2001 From: hyejiyu Date: Thu, 19 Sep 2024 02:19:10 +0900 Subject: [PATCH] modifed DAG --- airflow/dag.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/airflow/dag.py b/airflow/dag.py index cd912da..31ea4ea 100644 --- 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 )