uranusjr commented on a change in pull request #20349:
URL: https://github.com/apache/airflow/pull/20349#discussion_r783617068
##
File path: tests/jobs/test_scheduler_job.py
##
@@ -645,6 +645,36 @@ def
test_find_executable_task_instances_in_default_pool(self, dag_maker):
uranusjr commented on a change in pull request #20349:
URL: https://github.com/apache/airflow/pull/20349#discussion_r783616795
##
File path: airflow/jobs/scheduler_job.py
##
@@ -403,6 +403,15 @@ def _executable_task_instances_to_queued(self, max_tis:
int, session: Session =
uranusjr commented on a change in pull request #20349:
URL: https://github.com/apache/airflow/pull/20349#discussion_r782689415
##
File path: airflow/jobs/scheduler_job.py
##
@@ -402,6 +402,14 @@ def _executable_task_instances_to_queued(self, max_tis:
int, session: Session =
uranusjr commented on a change in pull request #20349:
URL: https://github.com/apache/airflow/pull/20349#discussion_r782688362
##
File path: airflow/jobs/scheduler_job.py
##
@@ -402,6 +402,14 @@ def _executable_task_instances_to_queued(self, max_tis:
int, session: Session =
uranusjr commented on a change in pull request #20349:
URL: https://github.com/apache/airflow/pull/20349#discussion_r773572622
##
File path: airflow/jobs/scheduler_job.py
##
@@ -402,6 +402,14 @@ def _executable_task_instances_to_queued(self, max_tis:
int, session: Session =