Airflow, Data Pipeline, Data, Workflow, Data Engineering.
more tasks will get queued. The default number of slots for a pool is 128. max_active_tis_per_dag This defines the maximum number of active task instances of this task across all active DAG runs. In earlier versions, it was defined using the parameter task_concurrency. t1 = Operator('task_id',