run pre-commit

Author: gwauge

docs/source/index.rst

@@ -157,8 +157,8 @@ Python's standard `logging framework`_.
 Errors
 ------
 
-The ``s3fs`` library includes a built-in mechanism to automatically retry 
-operations when specific transient errors occur. You can customize this behavior 
+The ``s3fs`` library includes a built-in mechanism to automatically retry
+operations when specific transient errors occur. You can customize this behavior
 by adding specific exception types or defining complex logic via custom handlers.
 
 Default Retryable Errors
@@ -176,7 +176,7 @@ By default, ``s3fs`` will retry the following exception types:
 Registering Custom Error Types
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
-To include additional exception types in the default retry logic, use the 
+To include additional exception types in the default retry logic, use the
 ``add_retryable_error`` function. This is useful for simple type-based retries.
 
 .. code-block:: python
@@ -188,10 +188,10 @@ To include additional exception types in the default retry logic, use the
 Implementing Custom Error Handlers
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
-For more complex scenarios, such as retrying based on an error message rather than 
+For more complex scenarios, such as retrying based on an error message rather than
 just the type, you can register a custom error handler using ``set_custom_error_handler``.
 
-The handler should be a callable that accepts an exception instance and returns ``True`` 
+The handler should be a callable that accepts an exception instance and returns ``True``
 if the error should be retried, or ``False`` otherwise.
 
 .. code-block:: python
@@ -203,9 +203,9 @@ if the error should be retried, or ``False`` otherwise.
 Handling AWS ClientErrors
 ~~~~~~~~~~~~~~~~~~~~~~~~~
 
-``s3fs`` provides specialized handling for ``botocore.exceptions.ClientError``. 
-While ``s3fs`` checks these against internal patterns (like throttling), 
-you can extend this behavior using a custom handler. Note that the internal 
+``s3fs`` provides specialized handling for ``botocore.exceptions.ClientError``.
+While ``s3fs`` checks these against internal patterns (like throttling),
+you can extend this behavior using a custom handler. Note that the internal
 patterns will still be checked and handled before the custom handler.
 
 .. code-block:: python

s3fs/core.py

@@ -73,6 +73,7 @@ def setup_logging(level=None):
 if ClientPayloadError is not None:
     S3_RETRYABLE_ERRORS += (ClientPayloadError,)
 
+
 def add_retryable_error(exc):
     """
     Add an exception type to the list of retryable S3 errors.
@@ -86,18 +87,21 @@ def add_retryable_error(exc):
     ----------
     >>> class MyCustomError(Exception):  # doctest: +SKIP
     ...     pass  # doctest: +SKIP
-    >>> add_retryable_error(MyCustomError)  # doctest: +SKIP    
+    >>> add_retryable_error(MyCustomError)  # doctest: +SKIP
     """
     global S3_RETRYABLE_ERRORS
     S3_RETRYABLE_ERRORS += (exc,)
 
+
 CUSTOM_ERROR_HANDLER = lambda _: False
+
+
 def set_custom_error_handler(func):
     """Set a custom error handler function for S3 retryable errors.
 
     The function should take an exception instance as its only argument,
     and return True if the operation should be retried, or False otherwise.
-    This can also be used for custom behavior on `ClientError` exceptions, 
+    This can also be used for custom behavior on `ClientError` exceptions,
     such as retrying other patterns.
 
     Parameters
@@ -118,6 +122,7 @@ def set_custom_error_handler(func):
     global CUSTOM_ERROR_HANDLER
     CUSTOM_ERROR_HANDLER = func
 
+
 _VALID_FILE_MODES = {"r", "w", "a", "rb", "wb", "ab"}
 
 _PRESERVE_KWARGS = [
@@ -151,13 +156,14 @@ def set_custom_error_handler(func):
 }
 buck_acls = {"private", "public-read", "public-read-write", "authenticated-read"}
 
+
 async def _error_wrapper(func, *, args=(), kwargs=None, retries):
     if kwargs is None:
         kwargs = {}
     err = None
     for i in range(retries):
         wait_time = min(1.7**i * 0.1, 15)
-        
+
         try:
             return await func(*args, **kwargs)
         except S3_RETRYABLE_ERRORS as e:
@@ -177,7 +183,7 @@ async def _error_wrapper(func, *, args=(), kwargs=None, retries):
                 if pattern in str(e):
                     matched = True
                     break
-            
+
             if matched:
                 await asyncio.sleep(wait_time)
             else: