clean up logic

Author: blink1073

pymongo/asynchronous/topology.py

@@ -868,8 +868,6 @@ async def _handle_error(self, address: _Address, err_ctx: _ErrorContext) -> None
             # as Unknown and request an immediate check of the server.
             # Otherwise, we clear the connection pool, mark the server as
             # Unknown and request an immediate check of the server.
-            if error.has_error_label("SystemOverloadedError"):
-                return
             if hasattr(error, "code"):
                 err_code = error.code
             else:
@@ -887,6 +885,9 @@ async def _handle_error(self, address: _Address, err_ctx: _ErrorContext) -> None
                 server.request_check()
             elif not err_ctx.completed_handshake:
                 # Unknown command error during the connection handshake.
+                # Ignore if it has the backpressure error label applied.
+                if error.has_error_label("SystemOverloadedError"):
+                    return
                 if not self._settings.load_balanced:
                     await self._process_change(ServerDescription(address, error=error))
                 # Clear the pool.

pymongo/synchronous/topology.py

@@ -866,8 +866,6 @@ def _handle_error(self, address: _Address, err_ctx: _ErrorContext) -> None:
             # as Unknown and request an immediate check of the server.
             # Otherwise, we clear the connection pool, mark the server as
             # Unknown and request an immediate check of the server.
-            if error.has_error_label("SystemOverloadedError"):
-                return
             if hasattr(error, "code"):
                 err_code = error.code
             else:
@@ -885,6 +883,9 @@ def _handle_error(self, address: _Address, err_ctx: _ErrorContext) -> None:
                 server.request_check()
             elif not err_ctx.completed_handshake:
                 # Unknown command error during the connection handshake.
+                # Ignore if it has the backpressure error label applied.
+                if error.has_error_label("SystemOverloadedError"):
+                    return
                 if not self._settings.load_balanced:
                     self._process_change(ServerDescription(address, error=error))
                 # Clear the pool.