Fix GRPC client not honouring call options

Signed-off-by: 🌲 Harry 🌊 John 🏔 <johrry@amazon.com>
cortexproject · Mar 5, 2024 · 64be403 · 64be403
1 parent c033170
commit 64be403
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/util/grpcutil/util.go b/pkg/util/grpcutil/util.go
@@ -69,7 +69,7 @@ func HTTPHeaderPropagationClientInterceptor(ctx context.Context, method string,
 func HTTPHeaderPropagationStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string,
 	streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
 	ctx = injectForwardedHeadersIntoMetadata(ctx)
-	return streamer(ctx, desc, cc, method)
+	return streamer(ctx, desc, cc, method, opts...)
 }
 
 // injectForwardedHeadersIntoMetadata implements HTTPHeaderPropagationClientInterceptor and HTTPHeaderPropagationStreamClientInterceptor