This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-management.git
The following commit(s) were added to refs/heads/main by this push:
new 35de634e improve rolling update code (#913)
35de634e is described below
commit 35de634ebada7c0f85831441c8cb77755f943649
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Aug 10 17:44:19 2026 +0100
improve rolling update code (#913)
---
.../apache/pekko/rollingupdate/kubernetes/KubernetesApiImpl.scala | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git
a/rolling-update-kubernetes/src/main/scala/org/apache/pekko/rollingupdate/kubernetes/KubernetesApiImpl.scala
b/rolling-update-kubernetes/src/main/scala/org/apache/pekko/rollingupdate/kubernetes/KubernetesApiImpl.scala
index 2a60d99a..460a1cc6 100644
---
a/rolling-update-kubernetes/src/main/scala/org/apache/pekko/rollingupdate/kubernetes/KubernetesApiImpl.scala
+++
b/rolling-update-kubernetes/src/main/scala/org/apache/pekko/rollingupdate/kubernetes/KubernetesApiImpl.scala
@@ -396,9 +396,8 @@ PUTs must contain resourceVersions. Response:
case StatusCodes.Unauthorized =>
handleUnauthorized(response)
case unexpected =>
- responseEntity
- .toStrict(settings.bodyReadTimeout)
- .flatMap(e => Unmarshal(e).to[String])
+ Unmarshal(responseEntity)
+ .to[String]
.map(body =>
throw new ReplicaSetException(
s"Unexpected response from API server when retrieving
ReplicaSet: $unexpected. Body: $body"))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
