Edit Oasis dag Error

HyejiYu · Sep 27, 2024 · e63d127 · e63d127
1 parent b9195a5
commit e63d127
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/airflow/Oasis_dag.py b/airflow/Oasis_dag.py
@@ -67,7 +67,5 @@ def generate_queue_values():
         bash_command="python3 /home/patturning1/oasis_consumer.py {{ params.consumer }}",  # 템플릿을 사용하여 매핑된 값 사용
     ).expand(params=generate_queue_values())
 
-    [
-        run_consumer_task,
-        send_post_request_OASIS_task.expand(),
-    ]
+    send_post_request_OASIS_task()
+    run_consumer_task