Apply codestyle across all codebase

- Trim white spaces in all files - Apply black to aiobotocore, examples, and tests - Apply isort to aiobotocore, examples, and tests
aio-libs · thehesiod · Jul 20, 2022 · Jul 3, 2022 · Jul 4, 2022 · Jul 4, 2022
commit 821a649c41e1a5295c7cbd9fd85d1a6d3596b94b
diff --git a/.github/pull_request_template.md b/.github/pull_request_template.md
@@ -10,7 +10,7 @@
   * [ ] Detailed description of issue
   * [ ] Alternative methods considered (if any)
   * [ ] How issue is being resolved
-  * [ ] How issue can be reproduced 
+  * [ ] How issue can be reproduced
 * [ ] If this is providing a new feature  (can be provided via link to issue with these details):
   * [ ] Detailed description of new feature
   * [ ] Why needed

diff --git a/.gitignore b/.gitignore
@@ -62,4 +62,4 @@ target/
 # rope
 .ropeproject
 
-Pipfile.lock
+Pipfile.lock
diff --git a/README.rst b/README.rst
@@ -173,7 +173,7 @@ Enable type checking and code completion
 ----------------------------------------
 
 Install types-aiobotocore_ that contains type annotations for `aiobotocore`
-and all supported botocore_ services. 
+and all supported botocore_ services.
 
 .. code:: bash
 

diff --git a/aiobotocore/_endpoint_helpers.py b/aiobotocore/_endpoint_helpers.py
@@ -1,9 +1,9 @@
-import aiohttp.http_exceptions
 import asyncio
+
+import aiohttp.http_exceptions
 import botocore.retryhandler
 import wrapt
 
-
 # Monkey patching: We need to insert the aiohttp exception equivalents
 # The only other way to do this would be to have another config file :(
 _aiohttp_retryable_exceptions = [

diff --git a/aiobotocore/_helpers.py b/aiobotocore/_helpers.py
@@ -1,9 +1,13 @@
 import inspect
 
 try:
-    from contextlib import asynccontextmanager  # noqa: F401 lgtm[py/unused-import]
+    from contextlib import (  # noqa: F401 lgtm[py/unused-import]
+        asynccontextmanager,
+    )
 except ImportError:
-    from async_generator import asynccontextmanager  # noqa: F401 E501, lgtm[py/unused-import]
+    from async_generator import (  # noqa: F401 E501, lgtm[py/unused-import]
+        asynccontextmanager,
+    )
 
 
 async def resolve_awaitable(obj):

diff --git a/aiobotocore/args.py b/aiobotocore/args.py
@@ -1,8 +1,8 @@
 import copy
 
-from botocore.args import ClientArgsCreator
-import botocore.serialize
 import botocore.parsers
+import botocore.serialize
+from botocore.args import ClientArgsCreator
 
 from .config import AioConfig
 from .endpoint import AioEndpointCreator
@@ -12,14 +12,29 @@
 class AioClientArgsCreator(ClientArgsCreator):
     # NOTE: we override this so we can pull out the custom AioConfig params and
     #       use an AioEndpointCreator
-    def get_client_args(self, service_model, region_name, is_secure,
-                        endpoint_url, verify, credentials, scoped_config,
-                        client_config, endpoint_bridge):
+    def get_client_args(
+        self,
+        service_model,
+        region_name,
+        is_secure,
+        endpoint_url,
+        verify,
+        credentials,
+        scoped_config,
+        client_config,
+        endpoint_bridge,
+    ):
         final_args = self.compute_client_args(
-            service_model, client_config, endpoint_bridge, region_name,
-            endpoint_url, is_secure, scoped_config)
+            service_model,
+            client_config,
+            endpoint_bridge,
+            region_name,
+            endpoint_url,
+            is_secure,
+            scoped_config,
+        )
 
-        service_name = final_args['service_name'] # noqa
+        service_name = final_args['service_name']  # noqa
         parameter_validation = final_args['parameter_validation']
         endpoint_config = final_args['endpoint_config']
         protocol = final_args['protocol']
@@ -33,10 +48,12 @@ def get_client_args(self, service_model, region_name, is_secure,
 
         event_emitter = copy.copy(self._event_emitter)
         signer = AioRequestSigner(
-            service_model.service_id, signing_region,
+            service_model.service_id,
+            signing_region,
             endpoint_config['signing_name'],
             endpoint_config['signature_version'],
-            credentials, event_emitter
+            credentials,
+            event_emitter,
         )
 
         config_kwargs['s3'] = s3_config
@@ -51,19 +68,23 @@ def get_client_args(self, service_model, region_name, is_secure,
         endpoint_creator = AioEndpointCreator(event_emitter)
 
         endpoint = endpoint_creator.create_endpoint(
-            service_model, region_name=endpoint_region_name,
-            endpoint_url=endpoint_config['endpoint_url'], verify=verify,
+            service_model,
+            region_name=endpoint_region_name,
+            endpoint_url=endpoint_config['endpoint_url'],
+            verify=verify,
             response_parser_factory=self._response_parser_factory,
             max_pool_connections=new_config.max_pool_connections,
             proxies=new_config.proxies,
             timeout=(new_config.connect_timeout, new_config.read_timeout),
             socket_options=socket_options,
             client_cert=new_config.client_cert,
             proxies_config=new_config.proxies_config,
-            connector_args=new_config.connector_args)
+            connector_args=new_config.connector_args,
+        )
 
         serializer = botocore.serialize.create_serializer(
-            protocol, parameter_validation)
+            protocol, parameter_validation
+        )
         response_parser = botocore.parsers.create_parser(protocol)
         return {
             'serializer': serializer,
@@ -75,5 +96,5 @@ def get_client_args(self, service_model, region_name, is_secure,
             'loader': self._loader,
             'client_config': new_config,
             'partition': partition,
-            'exceptions_factory': self._exceptions_factory
+            'exceptions_factory': self._exceptions_factory,
         }
diff --git a/aiobotocore/awsrequest.py b/aiobotocore/awsrequest.py
@@ -1,5 +1,5 @@
-from botocore.awsrequest import AWSResponse
 import botocore.utils
+from botocore.awsrequest import AWSResponse
 
 
 class AioAWSResponse(AWSResponse):
@@ -10,7 +10,7 @@ async def _content_prop(self):
 
         if self._content is None:
             # NOTE: this will cache the data in self.raw
-            self._content = await self.raw.read() or bytes()
+            self._content = await self.raw.read() or b''
 
         return self._content