spec/integration/transactions_examples_spec.rb in mongo-2.12.4 vs spec/integration/transactions_examples_spec.rb in mongo-2.13.0.beta1
- old
+ new
@@ -181,21 +181,24 @@
def update_employee_info(session)
employees_coll = session.client.use(:hr)[:employees]
events_coll = session.client.use(:reporting)[:events]
session.start_transaction(read_concern: { level: :snapshot },
- write_concern: { w: :majority })
+ write_concern: { w: :majority },
+ read: {mode: :primary})
employees_coll.update_one({ employee: 3 }, { '$set' => { status: 'Inactive'} },
session: session)
events_coll.insert_one({ employee: 3, status: { new: 'Inactive', old: 'Active' } },
session: session)
commit_with_retry(session)
end
session = client.start_session
begin
- run_transaction_with_retry(session) { |s| update_employee_info(s) }
+ run_transaction_with_retry(session) do
+ update_employee_info(session)
+ end
rescue StandardError => e
# Do something with error
raise
end