(self)
| 1187 | |
| 1188 | @client_context.require_no_standalone |
| 1189 | def test_read_concern(self): |
| 1190 | with self.client.start_session(causal_consistency=True) as s: |
| 1191 | coll = self.client.pymongo_test.test |
| 1192 | coll.insert_one({}, session=s) |
| 1193 | self.listener.reset() |
| 1194 | coll.find_one({}, session=s) |
| 1195 | read_concern = self.listener.started_events[0].command.get("readConcern") |
| 1196 | self.assertIsNotNone(read_concern) |
| 1197 | self.assertIsNone(read_concern.get("level")) |
| 1198 | self.assertIsNotNone(read_concern.get("afterClusterTime")) |
| 1199 | |
| 1200 | coll = coll.with_options(read_concern=ReadConcern("majority")) |
| 1201 | self.listener.reset() |
| 1202 | coll.find_one({}, session=s) |
| 1203 | read_concern = self.listener.started_events[0].command.get("readConcern") |
| 1204 | self.assertIsNotNone(read_concern) |
| 1205 | self.assertEqual(read_concern.get("level"), "majority") |
| 1206 | self.assertIsNotNone(read_concern.get("afterClusterTime")) |
| 1207 | |
| 1208 | @client_context.require_no_standalone |
| 1209 | def test_cluster_time_with_server_support(self): |
nothing calls this directly
no test coverage detected