Retry requests on APIForbiddenError

During k8s upgrade it may return APIForbiddenError, add this as valid exception for retry request. Signed-off-by: Vasyl Saienko <[email protected]>
nolar · Nov 8, 2024 · da0f971 · da0f971
1 parent a69dae0
commit da0f971
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kopf/_cogs/clients/api.py b/kopf/_cogs/clients/api.py
@@ -84,7 +84,8 @@ async def request(
             )
             await errors.check_response(response)  # but do not parse it!
 
-        except (aiohttp.ClientConnectionError, errors.APIServerError, asyncio.TimeoutError) as e:
+        # NOTE(vsaienko): during k8s upgrade API might throw 403 forbiden. Use retries for this exception as well.
+        except (aiohttp.ClientConnectionError, errors.APIServerError, asyncio.TimeoutError, errors.APIForbiddenError) as e:
             if backoff is None:  # i.e. the last or the only attempt.
                 logger.error(f"Request attempt {idx} failed; escalating: {what} -> {e!r}")
                 raise