From 39dd06b5b9da9c293fee5bee06b28e6ff6bae0cd Mon Sep 17 00:00:00 2001 From: Matthew Topol Date: Thu, 13 May 2021 09:05:17 -0700 Subject: [PATCH] ARROW-12746: [Go][Flight] append instead of overwriting outgoing metadata Closes #10297 from zeroshade/flight-client-metadata Authored-by: Matthew Topol Signed-off-by: Micah Kornfield --- go/arrow/flight/client_auth.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/go/arrow/flight/client_auth.go b/go/arrow/flight/client_auth.go index 5f7c151abf748..1c1e38ed7d2fb 100644 --- a/go/arrow/flight/client_auth.go +++ b/go/arrow/flight/client_auth.go @@ -65,7 +65,7 @@ func createClientAuthUnaryInterceptor(auth ClientAuthHandler) grpc.UnaryClientIn return status.Errorf(codes.Unauthenticated, "error retrieving token: %s", err) } - return invoker(metadata.NewOutgoingContext(ctx, metadata.Pairs(grpcAuthHeader, tok)), method, req, reply, cc, opts...) + return invoker(metadata.AppendToOutgoingContext(ctx, grpcAuthHeader, tok), method, req, reply, cc, opts...) } } @@ -86,6 +86,6 @@ func createClientAuthStreamInterceptor(auth ClientAuthHandler) grpc.StreamClient return nil, status.Errorf(codes.Unauthenticated, "error retrieving token: %s", err) } - return streamer(metadata.NewOutgoingContext(ctx, metadata.Pairs(grpcAuthHeader, tok)), desc, cc, method, opts...) + return streamer(metadata.AppendToOutgoingContext(ctx, grpcAuthHeader, tok), desc, cc, method, opts...) } }