CP review

NoahStapp · NoahStapp · commit 2bf2502fb655 · 2026-04-13T13:08:05.000-04:00
diff --git a/pymongo/asynchronous/collection.py b/pymongo/asynchronous/collection.py
@@ -251,7 +251,6 @@ def __init__(
             unicode_decode_error_handler="replace", document_class=dict
         )
         self._timeout = database.client.options.timeout
-        self._retry_policy = database.client._retry_policy
 
         if create or kwargs:
             if _IS_SYNC:
diff --git a/pymongo/asynchronous/database.py b/pymongo/asynchronous/database.py
@@ -135,7 +135,6 @@ def __init__(
         self._name = name
         self._client: AsyncMongoClient[_DocumentType] = client
         self._timeout = client.options.timeout
-        self._retry_policy = client._retry_policy
 
     @property
     def client(self) -> AsyncMongoClient[_DocumentType]:
diff --git a/pymongo/synchronous/collection.py b/pymongo/synchronous/collection.py
@@ -254,7 +254,6 @@ def __init__(
             unicode_decode_error_handler="replace", document_class=dict
         )
         self._timeout = database.client.options.timeout
-        self._retry_policy = database.client._retry_policy
 
         if create or kwargs:
             if _IS_SYNC:
diff --git a/pymongo/synchronous/database.py b/pymongo/synchronous/database.py
@@ -135,7 +135,6 @@ def __init__(
         self._name = name
         self._client: MongoClient[_DocumentType] = client
         self._timeout = client.options.timeout
-        self._retry_policy = client._retry_policy
 
     @property
     def client(self) -> MongoClient[_DocumentType]:
diff --git a/test/asynchronous/test_client_backpressure.py b/test/asynchronous/test_client_backpressure.py
@@ -37,7 +37,7 @@
 
 _IS_SYNC = False
 
-# Mock an system overload error.
+# Mock a system overload error.
 mock_overload_error = {
     "configureFailPoint": "failCommand",
     "mode": {"times": 1},
diff --git a/test/test_client_backpressure.py b/test/test_client_backpressure.py
@@ -37,7 +37,7 @@
 
 _IS_SYNC = True
 
-# Mock an system overload error.
+# Mock a system overload error.
 mock_overload_error = {
     "configureFailPoint": "failCommand",
     "mode": {"times": 1},

Original file line number	Diff line number	Diff line change
`@@ -251,7 +251,6 @@ def __init__(`
`251`	`251`	`unicode_decode_error_handler="replace", document_class=dict`
`252`	`252`	`)`
`253`	`253`	`self._timeout = database.client.options.timeout`
`254`		`- self._retry_policy = database.client._retry_policy`
`255`	`254`
`256`	`255`	`if create or kwargs:`
`257`	`256`	`if _IS_SYNC:`
Original file line number	Diff line number	Diff line change
`@@ -254,7 +254,6 @@ def __init__(`
`254`	`254`	`unicode_decode_error_handler="replace", document_class=dict`
`255`	`255`	`)`
`256`	`256`	`self._timeout = database.client.options.timeout`
`257`		`- self._retry_policy = database.client._retry_policy`
`258`	`257`
`259`	`258`	`if create or kwargs:`
`260`	`259`	`if _IS_SYNC:`