This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 7ce8504b022 Remove leftovers from #45184
clear_not_launched_queued_tasks removal (#68698)
7ce8504b022 is described below
commit 7ce8504b0226be4f2f90bbe3c6bd127ecfd9052a
Author: PoAn Yang <[email protected]>
AuthorDate: Tue Jun 23 14:39:27 2026 +0900
Remove leftovers from #45184 clear_not_launched_queued_tasks removal
(#68698)
Signed-off-by: PoAn Yang <[email protected]>
---
.../providers/cncf/kubernetes/executors/kubernetes_executor.py | 4 ----
.../src/airflow_shared/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 0dcc01537cb..4ddb189390b 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 @@ class KubernetesExecutor(BaseExecutor):
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 @@ class KubernetesExecutor(BaseExecutor):
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 0ba1563116f..6c51e32ff77 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"
