fix: demote already closed stream (#1992)

Fixes #1956
block · Jul 7, 2024 · 06b763e · 06b763e
1 parent a183b6f
commit 06b763e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/rpc/rpc.go b/internal/rpc/rpc.go
@@ -177,7 +177,7 @@ func RetryStreamingClientStream[Req, Resp any](
 		// We've hit an error.
 		_, closeErr := stream.CloseAndReceive()
 		if closeErr != nil {
-			logger.Logf(logLevel, "Failed to close stream: %s", closeErr)
+			logger.Logf(log.Debug, "Failed to close stream: %s", closeErr)
 		}
 
 		errored = true