@@ -2190,7 +2190,7 @@ async def test_check_and_mutate_row_failure_unauthorized(
21902190
21912191
21922192@CrossSync .convert_class (sync_name = "TestExportedMetrics" )
2193- class TestExportedExportedMetricsAsync (SystemTestRunner ):
2193+ class TestExportedMetricsAsync (SystemTestRunner ):
21942194
21952195 @CrossSync .drop
21962196 @pytest .fixture (scope = "session" )
@@ -2232,6 +2232,7 @@ async def table(self, client, table_id, instance_id):
22322232 async def test_read_rows (self , table , temp_rows , metrics_client ):
22332233 from datetime import datetime , timedelta , timezone
22342234 from google .cloud import monitoring_v3
2235+ import google .cloud .bigtable
22352236
22362237 await temp_rows .add_row (b"row_key_1" )
22372238 await temp_rows .add_row (b"row_key_2" )
@@ -2247,7 +2248,7 @@ async def test_read_rows(self, table, temp_rows, metrics_client):
22472248
22482249 interval = {"start_time" : start_time , "end_time" : end_time }
22492250 metric_filter = (
2250- 'metric.type = "bigtable.googleapis.com/client/attempt_latencies" AND metric.labels.client_name ! = "go -bigtable/1.40.0 "'
2251+ f 'metric.type = "bigtable.googleapis.com/client/attempt_latencies" AND metric.labels.client_name = "python -bigtable/{ google . cloud . bigtable . __version__ } "'
22512252 )
22522253 results = metrics_client .list_time_series (
22532254 name = f"projects/{ table .client .project } " ,
0 commit comments