[GitHub] [airflow] uranusjr commented on a change in pull request #20349: Fix Scheduler crash when executing task instances of missing DAG

2022-01-12 Thread GitBox
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):

[GitHub] [airflow] uranusjr commented on a change in pull request #20349: Fix Scheduler crash when executing task instances of missing DAG

2022-01-12 Thread GitBox
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 =

[GitHub] [airflow] uranusjr commented on a change in pull request #20349: Fix Scheduler crash when executing task instances of missing DAG

2022-01-11 Thread GitBox
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 =

[GitHub] [airflow] uranusjr commented on a change in pull request #20349: Fix Scheduler crash when executing task instances of missing DAG

2022-01-11 Thread GitBox
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 =

[GitHub] [airflow] uranusjr commented on a change in pull request #20349: Fix Scheduler crash when executing task instances of missing DAG

2021-12-21 Thread GitBox
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 =