(airflow) branch main updated: Remove unused Spark pod try number helper (#75787)

[shahar]

This is an automated email from the ASF dual-hosted git repository.

shahar1 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 b785c05164e Remove unused Spark pod try number helper (#75787)
b785c05164e is described below

commit b785c05164e70ddd7ad3e0d0bb4c90f1a54fbed9
Author: Hussein Awala <huss...@awala.fr>
AuthorDate: Tue Oct 27 22:07:28 2026 +0100

    Remove unused Spark pod try number helper (#75787)
    
    Spark driver reattachment selects matching pods directly, leaving this 
private try-number helper without callers.
---
 .../airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py | 6 ------
 1 file changed, 6 deletions(-)

diff --git 
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
 
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
index 062f0418dbf..f935dd4164e 100644
--- 
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
+++ 
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
@@ -223,12 +223,6 @@ class SparkKubernetesOperator(KubernetesPodOperator):
     def pod_manager(self) -> PodManager:
         return PodManager(kube_client=self.client)
 
-    def _try_numbers_match(self, context, pod) -> bool:
-        task_instance = context["task_instance"]
-        task_context_labels = self._get_ti_pod_labels(context)
-        pod_try_number = 
pod.metadata.labels.get(task_context_labels.get("try_number", ""), "")
-        return str(task_instance.try_number) == str(pod_try_number)
-
     @property
     def template_body(self):
         """Templated body for CustomObjectLauncher."""