Prevent KubernetesJobWatcher getting stuck on resource too old (#23521)
authorRuben Laguna <ruben.laguna@gmail.com>
Wed, 11 May 2022 06:25:49 +0000 (08:25 +0200)
committerGitHub <noreply@github.com>
Wed, 11 May 2022 06:25:49 +0000 (08:25 +0200)
commitdee05b2ebca6ab66f1b447837e11fe204f98b2df
tree35d0b1b81a24d0fb957ad5b27cd6ac76991af0c1
parentcfa95af7e83b067787d8d6596caa3bc97f4b25bd
Prevent KubernetesJobWatcher getting stuck on resource too old (#23521)

* Prevent KubernetesJobWatcher getting stuck on resource too old

If the watch fails because "resource too old" the
KubernetesJobWatcher should not retry with the same resource version
as that will end up in loop where there is no progress.

* Reset ResourceVersion().resource_version to 0
airflow/executors/kubernetes_executor.py
tests/executors/test_kubernetes_executor.py