Address lint etc

Author: yinghsienwu

google/auth/aio/transport/aiohttp.py

@@ -171,7 +171,7 @@ async def __call__(
             if isinstance(timeout, aiohttp.ClientTimeout):
                 client_timeout = timeout
             else:
-              client_timeout = aiohttp.ClientTimeout(total=timeout)
+                client_timeout = aiohttp.ClientTimeout(total=timeout)
             _helpers.request_log(_LOGGER, method, url, body, headers)
             response = await self._session.request(
                 method,

google/auth/aio/transport/sessions.py

@@ -39,8 +39,7 @@
         from aiohttp import ClientTimeout
     except ImportError:
         ClientTimeout = None
-        
-    
+
 @asynccontextmanager
 async def timeout_guard(timeout):
     """
@@ -212,6 +211,7 @@ async def get(
         headers: Optional[Mapping[str, str]] = None,
         max_allowed_time: float = transport._DEFAULT_TIMEOUT_SECONDS,
         timeout: Union[float, ClientTimeout] = transport._DEFAULT_TIMEOUT_SECONDS,
+        total_attempts: Optional[int] = transport.DEFAULT_MAX_RETRY_ATTEMPTS,
         **kwargs,
     ) -> transport.Response:
         return await self.request(
@@ -226,6 +226,7 @@ async def post(
         headers: Optional[Mapping[str, str]] = None,
         max_allowed_time: float = transport._DEFAULT_TIMEOUT_SECONDS,
         timeout: Union[float, ClientTimeout] = transport._DEFAULT_TIMEOUT_SECONDS,
+        total_attempts: Optional[int] = transport.DEFAULT_MAX_RETRY_ATTEMPTS,
         **kwargs,
     ) -> transport.Response:
         return await self.request(
@@ -240,6 +241,7 @@ async def put(
         headers: Optional[Mapping[str, str]] = None,
         max_allowed_time: float = transport._DEFAULT_TIMEOUT_SECONDS,
         timeout: Union[float, ClientTimeout] = transport._DEFAULT_TIMEOUT_SECONDS,
+        total_attempts: Optional[int] = transport.DEFAULT_MAX_RETRY_ATTEMPTS,
         **kwargs,
     ) -> transport.Response:
         return await self.request(
@@ -254,6 +256,7 @@ async def patch(
         headers: Optional[Mapping[str, str]] = None,
         max_allowed_time: float = transport._DEFAULT_TIMEOUT_SECONDS,
         timeout: Union[float, ClientTimeout] = transport._DEFAULT_TIMEOUT_SECONDS,
+        total_attempts: Optional[int] = transport.DEFAULT_MAX_RETRY_ATTEMPTS,
         **kwargs,
     ) -> transport.Response:
         return await self.request(
@@ -268,6 +271,7 @@ async def delete(
         headers: Optional[Mapping[str, str]] = None,
         max_allowed_time: float = transport._DEFAULT_TIMEOUT_SECONDS,
         timeout: float = transport._DEFAULT_TIMEOUT_SECONDS,
+        total_attempts: Optional[int] = transport.DEFAULT_MAX_RETRY_ATTEMPTS,
         **kwargs,
     ) -> transport.Response:
         return await self.request(