amoghrajesh commented on PR #69914: URL: https://github.com/apache/airflow/pull/69914#issuecomment-4979735155
@raphaelauv good comment, but that's covered already. `_get_pod_from_task_state_store` returning None (nothing persisted yet) falls straight through to `find_pod()`, the same label search `reattach_on_restart` always did. So, the crash-before-persist window youre describing falls to the exact old behavior for that one retry & the operator still checks for a matching pod via labels, same as `reattach_on_restart` always did. It only skips the label search once the identity is actually persisted on a later retry. -- 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]
