The GitHub Actions job "Tests (AMD)" on airflow.git/fix-kpo-trigger-reentry-404 
has failed.
Run started by GitHub user jekeanyanwu (triggered by eladkal).

Head commit for run:
faf14fe7d5edaf5a139f7f2dea86c0bd57cc294b / Jeff Ekeanyanwu 
<[email protected]>
Fix deferrable KPO trigger_reentry crash when pod is GC'd before re-entry

When KubernetesPodOperator runs in deferrable mode and the pod is reclaimed by
Kubernetes between the trigger firing and the worker re-entering the task,
the unguarded `self.pod = self.hook.get_pod(...)` in `trigger_reentry` raises
`ApiException(404)` and escapes. The dead-code `if not self.pod:` branch
intended to translate this to `PodNotFoundException` is never reached because
`get_pod` raises rather than returning `None`.

Wrap the `get_pod` call so that:
- Non-404 ApiExceptions re-raise unchanged.
- 404 + event status "success" returns cleanly (the trigger already observed
  the pod completed successfully; logs/XCom are unrecoverable but the task
  itself succeeded).
- 404 + non-success event raises `PodNotFoundException` (matches existing
  dead-code intent).

Refs #66715.

Report URL: https://github.com/apache/airflow/actions/runs/25676739047

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to