diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py index 754d835dc3481..56da0f43c7483 100644 --- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py +++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py @@ -305,6 +305,13 @@ def start(self) -> None: self.kube_config.worker_pods_queued_check_interval, self.clear_not_launched_queued_tasks, ) + + self.event_scheduler.call_regular_interval( + conf.getfloat("scheduler", "orphaned_tasks_check_interval", fallback=300.0), + self._adopt_completed_pods, + (self.kube_client,), + ) + # We also call this at startup as that's the most likely time to see # stuck queued tasks self.clear_not_launched_queued_tasks()