diff --git a/CHANGELOG.md b/CHANGELOG.md index dc3c6bf2a7..f15d821822 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -27,6 +27,7 @@ * [BUGFIX] Query Frontend: queries with negative offset should check whether it is cacheable or not. #5719 * [BUGFIX] Redis Cache: pass `cache_size` config correctly. #5734 * [BUGFIX] Distributor: Shuffle-Sharding with IngestionTenantShardSize == 0, default sharding strategy should be used #5189 +* [BUGFIX] Cortex: Fix GRPC stream clients not honoring overrides for call options. #5797 ## 1.16.0 2023-11-20 diff --git a/pkg/util/grpcutil/util.go b/pkg/util/grpcutil/util.go index 6e60f2e5cb..8da1c6916e 100644 --- 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