From b4a49b1be7fc807cca4659cdb5bfd95e7d64b2c7 Mon Sep 17 00:00:00 2001 From: Alvaro Viebrantz Date: Tue, 27 Sep 2022 11:09:51 -0400 Subject: [PATCH 1/2] fix(bigquery): bq connection auth scopes --- bigquery/integration_test.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/bigquery/integration_test.go b/bigquery/integration_test.go index f2034978fb5..3eb4e26815d 100644 --- a/bigquery/integration_test.go +++ b/bigquery/integration_test.go @@ -158,6 +158,7 @@ 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"))} + 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) } From 6bd9da4fb011b48f731c50c3cbd10432e6971563 Mon Sep 17 00:00:00 2001 From: Alvaro Viebrantz Date: Tue, 27 Sep 2022 14:28:28 -0400 Subject: [PATCH 2/2] fix(bigquery): policy tag manager auth scopes --- bigquery/integration_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/bigquery/integration_test.go b/bigquery/integration_test.go index 3eb4e26815d..2d2fcbe5394 100644 --- a/bigquery/integration_test.go +++ b/bigquery/integration_test.go @@ -157,7 +157,7 @@ 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()