feat(bigtable): enable new auth library and remove async refresh (#19943)

bhshkh · gemini-code-assist[bot] · web-flow · commit 0d3697b2f31a · 2026-06-10T13:23:08.000-07:00
Context: b/372244283

---------

Co-authored-by: gemini-code-assist[bot] &lt;176961590+gemini-code-assist[bot]@users.noreply.github.com&gt;
diff --git a/bigtable/admin.go b/bigtable/admin.go
@@ -36,6 +36,7 @@ import (
 	"google.golang.org/api/cloudresourcemanager/v1"
 	"google.golang.org/api/iterator"
 	"google.golang.org/api/option"
+	"google.golang.org/api/option/internaloption"
 	gtransport "google.golang.org/api/transport/grpc"
 	"google.golang.org/genproto/googleapis/rpc/status"
 	"google.golang.org/grpc/codes"
@@ -120,6 +121,7 @@ func NewAdminClient(ctx context.Context, project, instance string, opts ...optio
 	o = append(o, btopt.ClientInterceptorOptions(nil, nil)...)
 	// Need to add scopes for long running operations (for create table & snapshots)
 	o = append(o, option.WithScopes(cloudresourcemanager.CloudPlatformScope))
+	o = append(o, internaloption.EnableNewAuthLibrary())
 	o = append(o, opts...)
 	connPool, err := gtransport.DialPool(ctx, o...)
 	if err != nil {
diff --git a/bigtable/client.go b/bigtable/client.go
@@ -145,7 +145,7 @@ func NewClientWithConfig(ctx context.Context, project, instance string, config C
 	o = append(o, opts...)
 
 	// TODO(b/372244283): Remove after b/358175516 has been fixed
-	o = append(o, internaloption.EnableAsyncRefreshDryRun(metricsTracerFactory.newAsyncRefreshErrHandler()))
+	o = append(o, internaloption.EnableNewAuthLibrary())
 
 	disableRetryInfo := false
 
diff --git a/bigtable/metrics.go b/bigtable/metrics.go
@@ -220,7 +220,6 @@ type builtinMetricsTracerFactory struct {
 	clientBlockingLatencies metric.Float64Histogram
 	retryCount              metric.Int64Counter
 	connErrCount            metric.Int64Counter
-	debugTags               metric.Int64Counter
 }
 
 // Returns error only if metricsProvider is of unknown type. Rest all errors are swallowed
@@ -312,26 +311,6 @@ func builtInMeterProviderOptions(project string, opts ...option.ClientOption) ([
 	)}, nil
 }
 
-func (tf *builtinMetricsTracerFactory) newAsyncRefreshErrHandler() func() {
-	if !tf.enabled {
-		return func() {}
-	}
-
-	asyncRefreshMetricAttrs := tf.clientAttributes
-	asyncRefreshMetricAttrs = append(asyncRefreshMetricAttrs,
-		attribute.String(metricLabelKeyTag, "async_refresh_dry_run"),
-		// Table, cluster and zone are unknown at this point
-		// Use default values
-		attribute.String(monitoredResLabelKeyTable, defaultTable),
-		attribute.String(monitoredResLabelKeyCluster, defaultCluster),
-		attribute.String(monitoredResLabelKeyZone, defaultZone),
-	)
-	return func() {
-		tf.debugTags.Add(context.Background(), 1,
-			metric.WithAttributes(asyncRefreshMetricAttrs...))
-	}
-}
-
 func (tf *builtinMetricsTracerFactory) createInstruments(meter metric.Meter) error {
 	var err error
 
@@ -421,13 +400,7 @@ func (tf *builtinMetricsTracerFactory) createInstruments(meter metric.Meter) err
 		return err
 	}
 
-	// Create debug_tags
-	tf.debugTags, err = meter.Int64Counter(
-		metricNameDebugTags,
-		metric.WithDescription("A counter of internal client events used for debugging."),
-		metric.WithUnit(metricUnitCount),
-	)
-	return err
+	return nil
 }
 
 // builtinMetricsTracer is created one per operation
@@ -577,7 +550,6 @@ func (tf *builtinMetricsTracerFactory) createBuiltinMetricsTracer(ctx context.Co
 		instrumentClientBlockingLatencies: tf.clientBlockingLatencies,
 		instrumentRetryCount:              tf.retryCount,
 		instrumentConnErrCount:            tf.connErrCount,
-		instrumentDebugTags:               tf.debugTags,
 
 		tableName:   tableName,
 		isStreaming: isStreaming,
