[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

UnleashClient/api/async_api.py

@@ -1,18 +1,18 @@
 import asyncio
+import json
 from typing import Any, Mapping, Optional, Tuple
+
 import aiohttp
 
-import json
 from UnleashClient.api.packet_building import build_registration_packet
 from UnleashClient.constants import (
     APPLICATION_HEADERS,
     FEATURES_URL,
-    REGISTER_URL,
     METRICS_URL,
+    REGISTER_URL,
 )
 from UnleashClient.utils import LOGGER
 
-
 _TRANSIENT_ERROR_CODES = {500, 502, 504}
 
 

UnleashClient/api/packet_building.py

@@ -1,6 +1,8 @@
 from datetime import datetime, timezone
 from platform import python_implementation, python_version
+
 import yggdrasil_engine
+
 from UnleashClient.constants import (
     CLIENT_SPEC_VERSION,
     SDK_NAME,

tests/unit_tests/api/test_async_feature.py

@@ -1,4 +1,5 @@
 import json
+
 import pytest
 from aioresponses import aioresponses
 
@@ -20,54 +21,93 @@
 MOCK_FEATURE_RESPONSE = {"version": 1, "features": []}
 PROJECT_URL = f"{FULL_FEATURE_URL}?project={PROJECT_NAME}"
 
+
 @pytest.mark.asyncio
 async def test_get_feature_toggles_success():
     with aioresponses() as m:
-        m.get(FULL_FEATURE_URL, status=200, payload=MOCK_FEATURE_RESPONSE, headers={"etag": ETAG_VALUE})
+        m.get(
+            FULL_FEATURE_URL,
+            status=200,
+            payload=MOCK_FEATURE_RESPONSE,
+            headers={"etag": ETAG_VALUE},
+        )
 
         body, etag = await get_feature_toggles_async(
-            URL, APP_NAME, INSTANCE_ID, CUSTOM_HEADERS, CUSTOM_OPTIONS,
-            REQUEST_TIMEOUT, REQUEST_RETRIES
+            URL,
+            APP_NAME,
+            INSTANCE_ID,
+            CUSTOM_HEADERS,
+            CUSTOM_OPTIONS,
+            REQUEST_TIMEOUT,
+            REQUEST_RETRIES,
         )
 
     assert json.loads(body)["version"] == 1
     assert etag == ETAG_VALUE
 
+
 @pytest.mark.asyncio
 async def test_get_feature_toggles_project_and_etag_present():
     with aioresponses() as m:
         m.get(PROJECT_URL, status=304, headers={"etag": ETAG_VALUE})
 
         body, etag = await get_feature_toggles_async(
-            URL, APP_NAME, INSTANCE_ID, CUSTOM_HEADERS, CUSTOM_OPTIONS,
-            REQUEST_TIMEOUT, REQUEST_RETRIES, project=PROJECT_NAME, cached_etag=ETAG_VALUE
+            URL,
+            APP_NAME,
+            INSTANCE_ID,
+            CUSTOM_HEADERS,
+            CUSTOM_OPTIONS,
+            REQUEST_TIMEOUT,
+            REQUEST_RETRIES,
+            project=PROJECT_NAME,
+            cached_etag=ETAG_VALUE,
         )
 
     assert body is None
     assert etag == ETAG_VALUE
 
+
 @pytest.mark.asyncio
 async def test_get_feature_toggles_retries_then_success():
     with aioresponses() as m:
         m.get(PROJECT_URL, status=500)  # first attempt
-        m.get(PROJECT_URL, status=200, payload=MOCK_FEATURE_RESPONSE, headers={"etag": ETAG_VALUE})
+        m.get(
+            PROJECT_URL,
+            status=200,
+            payload=MOCK_FEATURE_RESPONSE,
+            headers={"etag": ETAG_VALUE},
+        )
 
         body, etag = await get_feature_toggles_async(
-            URL, APP_NAME, INSTANCE_ID, CUSTOM_HEADERS, CUSTOM_OPTIONS,
-            REQUEST_TIMEOUT, request_retries=1, project=PROJECT_NAME, cached_etag=ETAG_VALUE
+            URL,
+            APP_NAME,
+            INSTANCE_ID,
+            CUSTOM_HEADERS,
+            CUSTOM_OPTIONS,
+            REQUEST_TIMEOUT,
+            request_retries=1,
+            project=PROJECT_NAME,
+            cached_etag=ETAG_VALUE,
         )
 
     assert json.loads(body)["version"] == 1
     assert etag == ETAG_VALUE
 
+
 @pytest.mark.asyncio
 async def test_get_feature_toggles_failure_after_retries():
     with aioresponses() as m:
         m.get(PROJECT_URL, status=500)
         m.get(PROJECT_URL, status=500)
         body, etag = await get_feature_toggles_async(
-            URL, APP_NAME, INSTANCE_ID, CUSTOM_HEADERS, CUSTOM_OPTIONS,
-            REQUEST_TIMEOUT, request_retries=1, project=PROJECT_NAME
+            URL,
+            APP_NAME,
+            INSTANCE_ID,
+            CUSTOM_HEADERS,
+            CUSTOM_OPTIONS,
+            REQUEST_TIMEOUT,
+            request_retries=1,
+            project=PROJECT_NAME,
         )
     assert body is None
     assert etag == ""

tests/unit_tests/api/test_async_metrics.py

@@ -1,7 +1,8 @@
 import json
+
 import pytest
-from aioresponses import aioresponses
 from aiohttp import ClientConnectionError
+from aioresponses import aioresponses
 from yarl import URL as YURL
 
 from UnleashClient.api.async_api import send_metrics_async
@@ -51,4 +52,4 @@ async def test_send_metrics_async(status, inject_exception, expected):
         assert ("POST", YURL(FULL_METRICS_URL)) in m.requests
         call = m.requests[("POST", YURL(FULL_METRICS_URL))][0]
         sent = json.loads(call.kwargs["data"])
-        assert sent["connectionId"] == MOCK_METRICS_REQUEST["connectionId"]
+        assert sent["connectionId"] == MOCK_METRICS_REQUEST["connectionId"]

tests/unit_tests/api/test_async_register.py

@@ -1,11 +1,12 @@
 import json
+
 import pytest
-from aioresponses import aioresponses
 from aiohttp import ClientConnectionError
+from aioresponses import aioresponses
 from yarl import URL as YURL
 
 from UnleashClient.api.async_api import register_client_async
-from UnleashClient.constants import REGISTER_URL, CLIENT_SPEC_VERSION
+from UnleashClient.constants import CLIENT_SPEC_VERSION, REGISTER_URL
 
 BASE_URL = "https://example.com"
 FULL_REGISTER_URL = BASE_URL + REGISTER_URL