PYTHON-4938 Clarify write concern rules in the transactions spec (#2231)

test/asynchronous/test_transactions.py

@@ -586,5 +586,29 @@ class TestTransactionsConvenientAPI(AsyncTransactionsBase):
             self.assertFalse(s.in_transaction)
 
 
+class TestOptionsInsideTransactionProse(AsyncTransactionsBase):
+    @async_client_context.require_transactions
+    @async_client_context.require_no_standalone
+    async def test_case_1(self):
+        # Write concern not inherited from collection object inside transaction
+        # Create a MongoClient running against a configured sharded/replica set/load balanced cluster.
+        client = async_client_context.client
+        coll = client[self.db.name].test
+        await coll.delete_many({})
+        # Start a new session on the client.
+        async with client.start_session() as s:
+            # Start a transaction on the session.
+            await s.start_transaction()
+            # Instantiate a collection object in the driver with a default write concern of { w: 0 }.
+            inner_coll = coll.with_options(write_concern=WriteConcern(w=0))
+            # Insert the document { n: 1 } on the instantiated collection.
+            result = await inner_coll.insert_one({"n": 1}, session=s)
+            # Commit the transaction.
+            await s.commit_transaction()
+        # End the session.
+        # Ensure the document was inserted and no error was thrown from the transaction.
+        assert result.inserted_id is not None
+
+
 if __name__ == "__main__":
     unittest.main()

test/test_transactions.py

@@ -574,5 +574,29 @@ class TestTransactionsConvenientAPI(TransactionsBase):
             self.assertFalse(s.in_transaction)
 
 
+class TestOptionsInsideTransactionProse(TransactionsBase):
+    @client_context.require_transactions
+    @client_context.require_no_standalone
+    def test_case_1(self):
+        # Write concern not inherited from collection object inside transaction
+        # Create a MongoClient running against a configured sharded/replica set/load balanced cluster.
+        client = client_context.client
+        coll = client[self.db.name].test
+        coll.delete_many({})
+        # Start a new session on the client.
+        with client.start_session() as s:
+            # Start a transaction on the session.
+            s.start_transaction()
+            # Instantiate a collection object in the driver with a default write concern of { w: 0 }.
+            inner_coll = coll.with_options(write_concern=WriteConcern(w=0))
+            # Insert the document { n: 1 } on the instantiated collection.
+            result = inner_coll.insert_one({"n": 1}, session=s)
+            # Commit the transaction.
+            s.commit_transaction()
+        # End the session.
+        # Ensure the document was inserted and no error was thrown from the transaction.
+        assert result.inserted_id is not None
+
+
 if __name__ == "__main__":
     unittest.main()