From 09aa636aecd8c866eddb7b248bb7080c4692ebca Mon Sep 17 00:00:00 2001 From: PoAn Yang Date: Thu, 18 Jun 2026 14:52:31 +0900 Subject: [PATCH] Remove leftovers from #45184 clear_not_launched_queued_tasks removal Signed-off-by: PoAn Yang --- .../cncf/kubernetes/executors/kubernetes_executor.py | 4 ---- .../observability/metrics/metrics_template.yaml | 6 ------ 2 files changed, 10 deletions(-) diff --git a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py index 0dcc01537cb78..4ddb189390b3c 100644 --- a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py +++ b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py @@ -108,7 +108,6 @@ def __init__(self, *args, **kwargs): self.kube_client: client.CoreV1Api | None = None self.scheduler_job_id: str | None = None self._last_completed_pod_adoption = 0.0 - self.last_handled: dict[TaskInstanceKey, float] = {} self.kubernetes_queue: str | None = None self.task_publish_retries: Counter[TaskInstanceKey] = Counter() self.task_publish_max_retries = self.conf.getint( @@ -228,9 +227,6 @@ def execute_async( pod_template_file = None self.event_buffer[key] = (TaskInstanceState.QUEUED, self.scheduler_job_id) self.task_queue.put(KubernetesJob(key, command, kube_executor_config, pod_template_file)) - # We keep a temporary local record that we've handled this so we don't - # try and remove it from the QUEUED state while we process it - self.last_handled[key] = time.time() def queue_workload(self, workload: workloads.All, session: Session | None) -> None: from airflow.executors import workloads diff --git a/shared/observability/src/airflow_shared/observability/metrics/metrics_template.yaml b/shared/observability/src/airflow_shared/observability/metrics/metrics_template.yaml index 0ba1563116fe4..6c51e32ff7798 100644 --- a/shared/observability/src/airflow_shared/observability/metrics/metrics_template.yaml +++ b/shared/observability/src/airflow_shared/observability/metrics/metrics_template.yaml @@ -720,12 +720,6 @@ metrics: legacy_name: "-" name_variables: [] - - name: "kubernetes_executor.clear_not_launched_queued_tasks.duration" - description: "Milliseconds taken for clearing not launched queued tasks in Kubernetes Executor" - type: "timer" - legacy_name: "-" - name_variables: [] - - name: "kubernetes_executor.adopt_task_instances.duration" description: "Milliseconds taken to adopt the task instances in Kubernetes Executor" type: "timer"