diff --git a/airflow/providers/cncf/kubernetes/utils/pod_manager.py b/airflow/providers/cncf/kubernetes/utils/pod_manager.py index 0e736daa6aa76..281c82884a4e1 100644 --- a/airflow/providers/cncf/kubernetes/utils/pod_manager.py +++ b/airflow/providers/cncf/kubernetes/utils/pod_manager.py @@ -634,7 +634,7 @@ def container_is_terminated(self, pod: V1Pod, container_name: str) -> bool: remote_pod = self.read_pod(pod) return container_is_terminated(pod=remote_pod, container_name=container_name) - @tenacity.retry(stop=tenacity.stop_after_attempt(3), wait=tenacity.wait_exponential(), reraise=True) + @tenacity.retry(stop=tenacity.stop_after_attempt(6), wait=tenacity.wait_exponential(max=15), reraise=True) def read_pod_logs( self, pod: V1Pod, diff --git a/tests/providers/cncf/kubernetes/utils/test_pod_manager.py b/tests/providers/cncf/kubernetes/utils/test_pod_manager.py index fc09d6bb02e78..0300cd063947e 100644 --- a/tests/providers/cncf/kubernetes/utils/test_pod_manager.py +++ b/tests/providers/cncf/kubernetes/utils/test_pod_manager.py @@ -100,6 +100,9 @@ def test_read_pod_logs_retries_fails(self): BaseHTTPError("Boom"), BaseHTTPError("Boom"), BaseHTTPError("Boom"), + BaseHTTPError("Boom"), + BaseHTTPError("Boom"), + BaseHTTPError("Boom"), ] with pytest.raises(BaseHTTPError): self.pod_manager.read_pod_logs(pod=mock.sentinel, container_name="base")