avkirilishin commented on issue #21473: URL: https://github.com/apache/airflow/issues/21473#issuecomment-1034096600
This is duplicate of #20391 that is going to be fixed in 2.2.4. --- > From this experiment I can conclude that in some point the scheduler is limiting to 32 the number of tasks checked to transition from scheduled to queued state and ordering this query prioritizing the DAG A scheduled tasks that are forbidden to run due to the max_active_tasks usage. It depends on `max_tis_per_query` or on the executor available slots: https://github.com/apache/airflow/blob/07fe9e8c6acf8826ac1dcaf2ad8c94297a0f0c24/airflow/jobs/scheduler_job.py#L504-L530 -- 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]
