CP review

NoahStapp · NoahStapp · commit 4560d96e8841 · 2026-03-31T11:59:07.000-04:00
diff --git a/pymongo/asynchronous/mongo_client.py b/pymongo/asynchronous/mongo_client.py
@@ -2931,7 +2931,7 @@ async def run(self) -> T:
                     and self._server is not None
                     and (
                         self._client.topology_description.topology_type_name == "Sharded"
-                        or exc.has_error_label("SystemOverloadedError")
+                        or overloaded
                     )
                 ):
                     self._deprioritized_servers.append(self._server)
diff --git a/pymongo/synchronous/mongo_client.py b/pymongo/synchronous/mongo_client.py
@@ -2921,7 +2921,7 @@ def run(self) -> T:
                     and self._server is not None
                     and (
                         self._client.topology_description.topology_type_name == "Sharded"
-                        or exc.has_error_label("SystemOverloadedError")
+                        or overloaded
                     )
                 ):
                     self._deprioritized_servers.append(self._server)

Original file line number	Diff line number	Diff line change
`@@ -2931,7 +2931,7 @@ async def run(self) -> T:`
`2931`	`2931`	`and self._server is not None`
`2932`	`2932`	`and (`
`2933`	`2933`	`self._client.topology_description.topology_type_name == "Sharded"`
`2934`		`- or exc.has_error_label("SystemOverloadedError")`
	`2934`	`+ or overloaded`
`2935`	`2935`	`)`
`2936`	`2936`	`):`
`2937`	`2937`	`self._deprioritized_servers.append(self._server)`
Original file line number	Diff line number	Diff line change
`@@ -2921,7 +2921,7 @@ def run(self) -> T:`
`2921`	`2921`	`and self._server is not None`
`2922`	`2922`	`and (`
`2923`	`2923`	`self._client.topology_description.topology_type_name == "Sharded"`
`2924`		`- or exc.has_error_label("SystemOverloadedError")`
	`2924`	`+ or overloaded`
`2925`	`2925`	`)`
`2926`	`2926`	`):`
`2927`	`2927`	`self._deprioritized_servers.append(self._server)`