cipheraxat opened a new pull request, #70636: URL: https://github.com/apache/airflow/pull/70636
`KubernetesJobOperator.get_pods()` used to hammer `list_namespaced_pod` a few times with no delay, then fail if the Job controller had not created pods yet. In practice that race marks the task failed while the Job still runs to success, and a retry can start a second Job. This change waits up to `schedule_timeout_seconds`, polling every `startup_check_interval_seconds` (both already inherited from `KubernetesPodOperator`). The first probe stays immediate. Discovery also stops once `len(pods) >= parallelism`, and `discover_pods_retry_number` is deprecated as a no-op. closes: #70585 --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Cursor Grok 4.5 Generated-by: Cursor Grok 4.5 following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
