pre-commit fixes

Author: ci.datadog-api-spec

src/datadog_api_client/rest.py

@@ -25,9 +25,6 @@
 
 RETRY_AFTER_STATUS_CODES = frozenset([429, 500, 501, 502, 503, 504, 505, 506, 507, 509, 510, 511, 512])
 RETRY_ALLOWED_METHODS = frozenset(["GET", "PUT", "DELETE", "POST", "PATCH"])
-# apply sane default for calls to datadog API which has 60s timeout
-DEFAULT_TIMEOUT = 55
-DEFAULT_IDLE_CONN_MS = 55000
 
 
 class ClientRetry(urllib3.util.Retry):
@@ -143,7 +140,7 @@ def request(
         post_params = post_params or {}
         headers = headers or {}
 
-        timeout = urllib3.Timeout(total=DEFAULT_TIMEOUT)
+        timeout = None
         if request_timeout:
             if isinstance(request_timeout, (int, float)):
                 timeout = urllib3.Timeout(total=request_timeout)
@@ -243,13 +240,7 @@ def __init__(self, configuration):
         proxy = None
         if configuration.proxy:
             proxy = aiosonic.Proxy(configuration.proxy, configuration.proxy_headers)
-        pool_configs = {
-            ":default": aiosonic.PoolConfig(
-                max_conn_idle_ms=DEFAULT_IDLE_CONN_MS
-            )
-        }
-        connector = aiosonic.TCPConnector(pool_configs=pool_configs)
-        self._client = aiosonic.HTTPClient(connector=connector, proxy=proxy, verify_ssl=configuration.verify_ssl)
+        self._client = aiosonic.HTTPClient(proxy=proxy, verify_ssl=configuration.verify_ssl)
         self._configuration = configuration
 
     def close(self):
@@ -299,13 +290,13 @@ async def request(
                                 (connection, read) timeouts.
         """
         assert not post_params, "not supported for now"
-        from aiosonic.timeout import Timeouts  # type: ignore
-        timeout = Timeouts(request_timeout=DEFAULT_TIMEOUT)
         if request_timeout is not None:
+            from aiosonic.timeout import Timeouts  # type: ignore
+
             if isinstance(request_timeout, (int, float)):
-                timeout = Timeouts(request_timeout=request_timeout)
+                request_timeout = Timeouts(request_timeout=request_timeout)
             else:
-                timeout = Timeouts(sock_connect=request_timeout[0], sock_read=request_timeout[1])
+                request_timeout = Timeouts(sock_connect=request_timeout[0], sock_read=request_timeout[1])
         request_body = None
         if (
             "Content-Type" not in headers
@@ -326,7 +317,7 @@ async def request(
         counter = 0
         while True:
             response = await self._client.request(
-                url, method, headers, query_params, request_body, timeouts=timeout
+                url, method, headers, query_params, request_body, timeouts=request_timeout
             )
             retry = self._retry(method, response, counter)
             if not retry: