From 2bbe0f3f094b02dc17f560a4fbdea765dce2ba7a Mon Sep 17 00:00:00 2001
From: Viktor Liu <17948409+lixmal@users.noreply.github.com>
Date: Sat, 22 Mar 2025 11:56:00 +0100
Subject: [PATCH] [client] Don't permanently fail on flow grpc shutdown (#3557)

---
 flow/client/client.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flow/client/client.go b/flow/client/client.go
index 582407ed5..f4e9aee39 100644
--- a/flow/client/client.go
+++ b/flow/client/client.go
@@ -95,7 +95,7 @@ func (c *GRPCClient) Receive(ctx context.Context, interval time.Duration, msgHan
 
 func (c *GRPCClient) establishStreamAndReceive(ctx context.Context, msgHandler func(msg *proto.FlowEventAck) error) error {
 	if c.clientConn.GetState() == connectivity.Shutdown {
-		return backoff.Permanent(errors.New("connection to flow receiver has been shut down"))
+		return errors.New("connection to flow receiver has been shut down")
 	}
 
 	stream, err := c.realClient.Events(ctx, grpc.WaitForReady(true))