We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c200c2c commit 1d8c739Copy full SHA for 1d8c739
test/test_transactions.py
@@ -512,9 +512,11 @@ def kill_all_sessions():
512
# Assert final state is expected.
513
expected_c = test['outcome'].get('collection')
514
if expected_c is not None:
515
- # Read from the primary to ensure causal consistency.
+ # Read from the primary with local read concern to ensure causal
516
+ # consistency.
517
primary_coll = collection.with_options(
- read_preference=ReadPreference.PRIMARY)
518
+ read_preference=ReadPreference.PRIMARY,
519
+ read_concern=ReadConcern('local'))
520
self.assertEqual(list(primary_coll.find()), expected_c['data'])
521
522
return run_scenario
0 commit comments