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

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

Author: pre-commit-ci[bot]

UnleashClient/__init__.py

@@ -16,14 +16,14 @@
 
 from UnleashClient.api import register_client
 from UnleashClient.constants import (
+    APPLICATION_HEADERS,
     DISABLED_VARIATION,
     ETAG,
     METRIC_LAST_SENT_TIME,
     REQUEST_RETRIES,
     REQUEST_TIMEOUT,
     SDK_NAME,
     SDK_VERSION,
-    APPLICATION_HEADERS,
 )
 from UnleashClient.events import (
     BaseEvent,
@@ -312,10 +312,21 @@ def initialize_client(self, fetch_toggles: bool = True) -> None:
                     )
 
                 # Decide mode
-                mode = (self.experimental_mode or {}).get("type") if self.experimental_mode else None
-                format_mode = (self.experimental_mode or {}).get("format") if self.experimental_mode else None
+                mode = (
+                    (self.experimental_mode or {}).get("type")
+                    if self.experimental_mode
+                    else None
+                )
+                format_mode = (
+                    (self.experimental_mode or {}).get("format")
+                    if self.experimental_mode
+                    else None
+                )
 
-                if fetch_toggles and (mode is None or (mode == "polling" and (format_mode in (None, "full")))):
+                if fetch_toggles and (
+                    mode is None
+                    or (mode == "polling" and (format_mode in (None, "full")))
+                ):
                     # Default/full polling
                     fetch_headers = {
                         **base_headers,
@@ -348,8 +359,8 @@ def initialize_client(self, fetch_toggles: bool = True) -> None:
                         executor=self.unleash_executor_name,
                         kwargs=job_args,
                     )
-                elif fetch_toggles and mode == "streaming": # Streaming mode
-                   
+                elif fetch_toggles and mode == "streaming":  # Streaming mode
+
                     stream_headers = {
                         **base_headers,
                         "unleash-interval": self.unleash_refresh_interval_str_millis,
@@ -367,7 +378,7 @@ def initialize_client(self, fetch_toggles: bool = True) -> None:
 
                     # Start metrics job only
                     self.unleash_scheduler.start()
-                else: # No fetching - only load from cache
+                else:  # No fetching - only load from cache
                     job_args = {
                         "cache": self.cache,
                         "engine": self.engine,

UnleashClient/streaming/manager.py

@@ -5,10 +5,10 @@
 
 from ld_eventsource import SSEClient
 from ld_eventsource.config import ConnectStrategy
+from yggdrasil_engine.engine import UnleashEngine
 
 from UnleashClient.constants import STREAMING_URL
 from UnleashClient.utils import LOGGER
-from yggdrasil_engine.engine import UnleashEngine
 
 
 class StreamingManager:
@@ -55,7 +55,9 @@ def start(self):
         if self._thread and self._thread.is_alive():
             return
         self._stop.clear()
-        self._thread = threading.Thread(target=self._run, name="UnleashStreaming", daemon=True)
+        self._thread = threading.Thread(
+            target=self._run, name="UnleashStreaming", daemon=True
+        )
         self._thread.start()
 
     def stop(self):
@@ -115,7 +117,9 @@ def _run(self):
                     LOGGER.debug("Ignoring SSE event type: %s", event.event)
 
                 # Heartbeat timeout: trigger reconnect via SSEClient interrupt (uses internal retry)
-                if self._hb_timeout and (time.time() - last_event_time > self._hb_timeout):
+                if self._hb_timeout and (
+                    time.time() - last_event_time > self._hb_timeout
+                ):
                     LOGGER.warning("Heartbeat timeout exceeded; reconnecting")
                     try:
                         client.interrupt()