Skip to content
This repository was archived by the owner on Apr 1, 2026. It is now read-only.

Commit b91da1c

Browse files
committed
updated mutate_rows test
1 parent 3b146f5 commit b91da1c

1 file changed

Lines changed: 8 additions & 2 deletions

File tree

tests/system/data/test_metrics_async.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1241,7 +1241,13 @@ async def test_bulk_mutate_rows_failure_unauthorized(
12411241
async def test_bulk_mutate_rows_failure_unauthorized_with_retries(
12421242
self, handler, authorized_view, cluster_config
12431243
):
1244-
"""retry unauthorized request multiple times before timing out"""
1244+
"""
1245+
retry unauthorized request multiple times before timing out
1246+
1247+
For bulk_mutate, the rpc returns success, with failures returned in the response.
1248+
For this reason, We expect the attempts to be marked as successful, even though
1249+
the underlying mutation is retried
1250+
"""
12451251
from google.cloud.bigtable.data.mutations import RowMutationEntry, SetCell
12461252
from google.cloud.bigtable.data.exceptions import MutationsExceptionGroup
12471253

@@ -1270,7 +1276,7 @@ async def test_bulk_mutate_rows_failure_unauthorized_with_retries(
12701276
)
12711277
# validate attempts
12721278
for attempt in handler.completed_attempts:
1273-
assert attempt.end_status.name == "PERMISSION_DENIED"
1279+
assert attempt.end_status.name == "OK"
12741280
assert (
12751281
attempt.gfe_latency_ns >= 0
12761282
and attempt.gfe_latency_ns < operation.duration_ns

0 commit comments

Comments
 (0)