This repository was archived by the owner on Mar 31, 2026. It is now read-only.
File tree Expand file tree Collapse file tree 2 files changed +33
-1
lines changed
Expand file tree Collapse file tree 2 files changed +33
-1
lines changed Original file line number Diff line number Diff line change @@ -227,7 +227,7 @@ def unit(session, protobuf_implementation):
227227 "--cov-config=.coveragerc" ,
228228 "--cov-report=" ,
229229 "--cov-fail-under=0" ,
230- os .path .join ("tests" , "unit" ),
230+ # os.path.join("tests", "unit"),
231231 * session .posargs ,
232232 env = {
233233 "PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION" : protobuf_implementation ,
Original file line number Diff line number Diff line change @@ -1071,6 +1071,38 @@ def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_
10711071 )
10721072
10731073 self .assertEqual (api .execute_batch_dml .call_count , 2 )
1074+ a = mock .call (
1075+ request = self ._batch_update_expected_request (),
1076+ metadata = [
1077+ ("google-cloud-resource-prefix" , database .name ),
1078+ ("x-goog-spanner-route-to-leader" , "true" ),
1079+ (
1080+ "x-goog-spanner-request-id" ,
1081+ f"1.{ REQ_RAND_PROCESS_ID } .{ database ._nth_client_id } .{ database ._channel_id } .1.1" ,
1082+ ),
1083+ ],
1084+ retry = RETRY ,
1085+ timeout = TIMEOUT ,
1086+ )
1087+ b = mock .call (
1088+ request = self ._batch_update_expected_request (begin = False ),
1089+ metadata = [
1090+ ("google-cloud-resource-prefix" , database .name ),
1091+ ("x-goog-spanner-route-to-leader" , "true" ),
1092+ (
1093+ "x-goog-spanner-request-id" ,
1094+ f"1.{ REQ_RAND_PROCESS_ID } .{ database ._nth_client_id } .{ database ._channel_id } .2.1" ,
1095+ ),
1096+ ],
1097+ retry = RETRY ,
1098+ timeout = TIMEOUT ,
1099+ )
1100+ print ("A: " , a )
1101+ print ("B: " , b )
1102+
1103+
1104+
1105+
10741106 self .assertEqual (
10751107 api .execute_batch_dml .call_args_list ,
10761108 [
You can’t perform that action at this time.
0 commit comments