hussein-awala commented on issue #29084:
URL: https://github.com/apache/airflow/issues/29084#issuecomment-1399347704

   It will be available as parameter for `BaseOperator` for Dynamic Task 
Mapping and normal tasks, but it will be useful only in the Dynamic Task 
Mapping case, where in the normal tasks, the number of the active tis per run 
is always <=1.
   
   > I think it should be set on DAG level and work with DAG.max_active_tasks 
and DAG.max_active_runs as well as other concurrency limitation:
   DAG.max_active_tasks_per_tun x DAG.max_active_runs <= DAG.max_active_tasks
   
   It's more a task configuration than dag configuration similar to 
`max_active_tis_per_dag`.
   There is a big difference between `max_active_tasks` which control the 
number of task instances allowed to run concurrently in all the dag runs, and 
`max_active_tis_per_dag` which control the number of task instances for **a 
specific task** allowed to run concurrently in all the dag runs.
   
   The configuration I propose is similar to `max_active_tis_per_dag` but in 
each run.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to