jscheffl commented on code in PR #58033:
URL: https://github.com/apache/airflow/pull/58033#discussion_r2512322701
##########
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py:
##########
@@ -78,7 +78,8 @@ class PodLaunchFailedException(AirflowException):
def should_retry_start_pod(exception: BaseException) -> bool:
"""Check if an Exception indicates a transient error and warrants
retrying."""
if isinstance(exception, ApiException):
- return str(exception.status) == "409"
+ # Retry on status code 409 (Conflict) or 429 (Too Many Requests)
+ return str(exception.status) in {"409", "429"}
Review Comment:
THanks for the rework and cool that you consolidated all the decorators to
common funtions.
Now CI has turned red but I assume once you fixed this up I would be happy
to merge!
--
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]
