do not try and label errors

Author: blink1073

pymongo/asynchronous/pool.py

@@ -17,7 +17,6 @@
 import asyncio
 import collections
 import contextlib
-import errno
 import logging
 import os
 import sys
@@ -1036,18 +1035,8 @@ def _handle_connection_error(self, error: BaseException, phase: str) -> None:
         # errno == errno.ECONNRESET or raised from an OSError that we've created due to
         # a closed connection.
         # If found, set backoff and add error labels.
-        if self.is_sdam or type(error) != AutoReconnect or not len(error.errors):
+        if self.is_sdam or type(error) != AutoReconnect:
             return
-        if hasattr(error.errors, "values"):
-            root_err = next(iter(error.errors.values()))
-        else:
-            root_err = error.errors[0]
-        if isinstance(root_err, ConnectionResetError):
-            if root_err.errno != errno.ECONNRESET:
-                return
-        elif isinstance(root_err, OSError):
-            if str(root_err) != "connection closed":
-                return
         self._backoff += 1
         error._add_error_label("SystemOverloadedError")
         error._add_error_label("RetryableError")

pymongo/pool_shared.py

@@ -149,7 +149,7 @@ def _raise_connection_failure(
         # 'timed out' appears in all the timeout related SSLErrors raised.
         raise NetworkTimeout(msg) from error
     else:
-        raise AutoReconnect(msg, errors=[error]) from error
+        raise AutoReconnect(msg) from error
 
 
 class _CancellationContext:

pymongo/synchronous/pool.py

@@ -17,7 +17,6 @@
 import asyncio
 import collections
 import contextlib
-import errno
 import logging
 import os
 import sys
@@ -1032,18 +1031,8 @@ def _handle_connection_error(self, error: BaseException, phase: str) -> None:
         # errno == errno.ECONNRESET or raised from an OSError that we've created due to
         # a closed connection.
         # If found, set backoff and add error labels.
-        if self.is_sdam or type(error) != AutoReconnect or not len(error.errors):
+        if self.is_sdam or type(error) != AutoReconnect:
             return
-        if hasattr(error.errors, "values"):
-            root_err = next(iter(error.errors.values()))
-        else:
-            root_err = error.errors[0]
-        if isinstance(root_err, ConnectionResetError):
-            if root_err.errno != errno.ECONNRESET:
-                return
-        elif isinstance(root_err, OSError):
-            if str(root_err) != "connection closed":
-                return
         self._backoff += 1
         error._add_error_label("SystemOverloadedError")
         error._add_error_label("RetryableError")