From 8e09288185f721d90288c3aa873980fc44b98613 Mon Sep 17 00:00:00 2001 From: Alvaro Viebrantz Date: Tue, 27 Sep 2022 14:22:24 -0700 Subject: [PATCH] fix(bigquery): bq connection auth scopes (#6752) Resolves #6744 --- bigquery/integration_test.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/bigquery/integration_test.go b/bigquery/integration_test.go index f2034978fb5..2d2fcbe5394 100644 --- a/bigquery/integration_test.go +++ b/bigquery/integration_test.go @@ -157,7 +157,8 @@ func initIntegrationTest() func() { } bqOpts := []option.ClientOption{option.WithTokenSource(ts)} sOpts := []option.ClientOption{option.WithTokenSource(testutil.TokenSource(ctx, storage.ScopeFullControl))} - ptmOpts := []option.ClientOption{option.WithTokenSource(testutil.TokenSource(ctx, "https://www.googleapis.com/auth/cloud-platform"))} + ptmOpts := []option.ClientOption{option.WithTokenSource(testutil.TokenSource(ctx, datacatalog.DefaultAuthScopes()...))} + connOpts := []option.ClientOption{option.WithTokenSource(testutil.TokenSource(ctx, connection.DefaultAuthScopes()...))} cleanup := func() {} now := time.Now().UTC() if *record { @@ -196,6 +197,7 @@ func initIntegrationTest() func() { bqOpts = append(bqOpts, grpcHeadersChecker.CallOptions()...) sOpts = append(sOpts, grpcHeadersChecker.CallOptions()...) ptmOpts = append(ptmOpts, grpcHeadersChecker.CallOptions()...) + connOpts = append(sOpts, grpcHeadersChecker.CallOptions()...) } var err error client, err = NewClient(ctx, projID, bqOpts...) @@ -210,7 +212,7 @@ func initIntegrationTest() func() { if err != nil { log.Fatalf("datacatalog.NewPolicyTagManagerClient: %v", err) } - connectionsClient, err = connection.NewClient(ctx, sOpts...) + connectionsClient, err = connection.NewClient(ctx, connOpts...) if err != nil { log.Fatalf("connection.NewService: %v", err) }