[Apache Airflow] Sending task to a specific queue less than 1 minute read Sending task to a specific queue queue="[queue_name]" ... transform = BashOperator( task_id="transform", queue="high_cpu", bash_commands="sleep 10" ) ... Share on Twitter Facebook LinkedIn Previous Next