@@ -1128,7 +1128,9 @@ def test_causal_consistency(self):
1128
1128
# Start Causal Consistency Example 1
1129
1129
with client .start_session (causal_consistency = True ) as s1 :
1130
1130
current_date = datetime .datetime .today ()
1131
- items = client .get_database ('test' ).items
1131
+ items = client .get_database (
1132
+ 'test' , read_concern = ReadConcern ('majority' ),
1133
+ write_concern = WriteConcern ('majority' , wtimeout = 1000 )).items
1132
1134
items .update_one (
1133
1135
{'sku' : "111" , 'end' : None },
1134
1136
{'$set' : {'end' : current_date }}, session = s1 )
@@ -1143,7 +1145,9 @@ def test_causal_consistency(self):
1143
1145
s2 .advance_operation_time (s1 .operation_time )
1144
1146
1145
1147
items = client .get_database (
1146
- 'test' , read_preference = ReadPreference .SECONDARY ).items
1148
+ 'test' , read_preference = ReadPreference .SECONDARY ,
1149
+ read_concern = ReadConcern ('majority' ),
1150
+ write_concern = WriteConcern ('majority' , wtimeout = 1000 )).items
1147
1151
for item in items .find ({'end' : None }, session = s2 ):
1148
1152
print (item )
1149
1153
# End Causal Consistency Example 2
0 commit comments