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

Commit d5bbd62

Browse files
1 parent 5ace29f commit d5bbd62

1 file changed

Lines changed: 10 additions & 6 deletions

File tree

tests/unit/test_spanner.py

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1108,22 +1108,26 @@ def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_
11081108
self._batch_update_expected_request(begin=False),
11091109
]
11101110

1111-
actual_requests = [call.kwargs['request'] for call in call_args_list]
1111+
actual_requests = [call.kwargs["request"] for call in call_args_list]
11121112
self.assertCountEqual(actual_requests, expected_requests)
11131113

11141114
request_ids = []
11151115
for call in call_args_list:
1116-
metadata = call.kwargs['metadata']
1116+
metadata = call.kwargs["metadata"]
11171117
self.assertEqual(len(metadata), 3)
1118-
self.assertEqual(metadata[0], ("google-cloud-resource-prefix", database.name))
1118+
self.assertEqual(
1119+
metadata[0], ("google-cloud-resource-prefix", database.name)
1120+
)
11191121
self.assertEqual(metadata[1], ("x-goog-spanner-route-to-leader", "true"))
11201122
self.assertEqual(metadata[2][0], "x-goog-spanner-request-id")
11211123
request_ids.append(metadata[2][1])
1122-
self.assertEqual(call.kwargs['retry'], RETRY)
1123-
self.assertEqual(call.kwargs['timeout'], TIMEOUT)
1124+
self.assertEqual(call.kwargs["retry"], RETRY)
1125+
self.assertEqual(call.kwargs["timeout"], TIMEOUT)
11241126

11251127
expected_id_suffixes = ["1.1", "2.1"]
1126-
actual_id_suffixes = sorted([".".join(rid.split('.')[-2:]) for rid in request_ids])
1128+
actual_id_suffixes = sorted(
1129+
[".".join(rid.split(".")[-2:]) for rid in request_ids]
1130+
)
11271131
self.assertEqual(actual_id_suffixes, expected_id_suffixes)
11281132

11291133
def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_read(

0 commit comments

Comments
 (0)