|
14 | 14 |
|
15 | 15 |
|
16 | 16 | import threading |
| 17 | +import unittest |
| 18 | + |
| 19 | +import pytest |
17 | 20 | from google.protobuf.struct_pb2 import Struct |
18 | 21 | from google.cloud.spanner_v1 import ( |
19 | 22 | PartialResultSet, |
@@ -955,7 +958,9 @@ def test_transaction_should_use_transaction_id_returned_by_first_batch_update(se |
955 | 958 | timeout=TIMEOUT, |
956 | 959 | ) |
957 | 960 |
|
958 | | - @pytest.mark.skip(reason="Inherently flaky, relies on thread crash swallowing in older Pytest") |
| 961 | + @pytest.mark.skip( |
| 962 | + reason="Inherently flaky, relies on thread crash swallowing in older Pytest" |
| 963 | + ) |
959 | 964 | def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_execute_update( |
960 | 965 | self, |
961 | 966 | ): |
@@ -1029,7 +1034,9 @@ def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_ |
1029 | 1034 | self.assertEqual(api.execute_sql.call_count, 2) |
1030 | 1035 | self.assertEqual(api.execute_batch_dml.call_count, 1) |
1031 | 1036 |
|
1032 | | - @pytest.mark.skip(reason="Inherently flaky, relies on thread crash swallowing in older Pytest") |
| 1037 | + @pytest.mark.skip( |
| 1038 | + reason="Inherently flaky, relies on thread crash swallowing in older Pytest" |
| 1039 | + ) |
1033 | 1040 | def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_batch_update( |
1034 | 1041 | self, |
1035 | 1042 | ): |
@@ -1096,7 +1103,9 @@ def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_ |
1096 | 1103 | ) |
1097 | 1104 | self.assertEqual(actual_id_suffixes, expected_id_suffixes) |
1098 | 1105 |
|
1099 | | - @pytest.mark.skip(reason="Inherently flaky, relies on thread crash swallowing in older Pytest") |
| 1106 | + @pytest.mark.skip( |
| 1107 | + reason="Inherently flaky, relies on thread crash swallowing in older Pytest" |
| 1108 | + ) |
1100 | 1109 | def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_read( |
1101 | 1110 | self, |
1102 | 1111 | ): |
@@ -1170,7 +1179,9 @@ def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_ |
1170 | 1179 | ) |
1171 | 1180 | self.assertEqual(actual_id_suffixes, expected_id_suffixes) |
1172 | 1181 |
|
1173 | | - @pytest.mark.skip(reason="Inherently flaky, relies on thread crash swallowing in older Pytest") |
| 1182 | + @pytest.mark.skip( |
| 1183 | + reason="Inherently flaky, relies on thread crash swallowing in older Pytest" |
| 1184 | + ) |
1174 | 1185 | def test_transaction_for_concurrent_statement_should_begin_one_transaction_with_query( |
1175 | 1186 | self, |
1176 | 1187 | ): |
|
0 commit comments