Airflow, Data Pipeline, Data, Workflow, Data Engineering.
concurrency parameters to set this control. max_active_runs This defines the maximum number of active runs of the given DAG. If not set explicitly it defaults to max_active_runs_per_dag. d = DAG('my_cool_dag', max_active_tasks=10, max_active_runs=2) d = DAG('my_cool_dag', concurrency=10,