[GitHub] [airflow] RNHTTR commented on a diff in pull request #30375: Simplify logic to resolve tasks stuck in queued despite stalled_task_timeout

RNHTTR commented on code in PR #30375: URL: https://github.com/apache/airflow/pull/30375#discussion_r1279626962 ## airflow/executors/celery_executor.py: ## @@ -543,22 +417,28 @@ def try_adopt_task_instances(self, tis: Sequence[TaskInstance]) -> Sequence[Task return n

[GitHub] [airflow] RNHTTR commented on a diff in pull request #30375: Simplify logic to resolve tasks stuck in queued despite stalled_task_timeout

RNHTTR commented on code in PR #30375: URL: https://github.com/apache/airflow/pull/30375#discussion_r1170250855 ## airflow/executors/celery_executor.py: ## @@ -543,22 +417,28 @@ def try_adopt_task_instances(self, tis: Sequence[TaskInstance]) -> Sequence[Task return n

[GitHub] [airflow] RNHTTR commented on a diff in pull request #30375: Simplify logic to resolve tasks stuck in queued despite stalled_task_timeout

RNHTTR commented on code in PR #30375: URL: https://github.com/apache/airflow/pull/30375#discussion_r1164608101 ## airflow/executors/celery_executor.py: ## @@ -543,22 +417,28 @@ def try_adopt_task_instances(self, tis: Sequence[TaskInstance]) -> Sequence[Task return n

[GitHub] [airflow] RNHTTR commented on a diff in pull request #30375: Simplify logic to resolve tasks stuck in queued despite stalled_task_timeout

RNHTTR commented on code in PR #30375: URL: https://github.com/apache/airflow/pull/30375#discussion_r1164531793 ## airflow/executors/celery_executor.py: ## @@ -543,22 +417,28 @@ def try_adopt_task_instances(self, tis: Sequence[TaskInstance]) -> Sequence[Task return n

[GitHub] [airflow] RNHTTR commented on a diff in pull request #30375: Simplify logic to resolve tasks stuck in queued despite stalled_task_timeout

RNHTTR commented on code in PR #30375: URL: https://github.com/apache/airflow/pull/30375#discussion_r1157712035 ## airflow/jobs/scheduler_job.py: ## @@ -152,6 +152,43 @@ def __init__( self._zombie_threshold_secs = conf.getint("scheduler", "scheduler_zombie_task_thresho

[GitHub] [airflow] RNHTTR commented on a diff in pull request #30375: Simplify logic to resolve tasks stuck in queued despite stalled_task_timeout

RNHTTR commented on code in PR #30375: URL: https://github.com/apache/airflow/pull/30375#discussion_r1157632498 ## airflow/jobs/scheduler_job.py: ## @@ -152,6 +152,43 @@ def __init__( self._zombie_threshold_secs = conf.getint("scheduler", "scheduler_zombie_task_thresho