diff --git a/airflow/Oasis_dag.py b/airflow/Oasis_dag.py index 3d7f1e3..0dc7aa9 100644 --- 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