lint

Author: JamieSinn

devcycle_python_sdk/managers/config_manager.py

@@ -22,10 +22,10 @@
 
 class EnvironmentConfigManager(threading.Thread):
     def __init__(
-            self,
-            sdk_key: str,
-            options: DevCycleLocalOptions,
-            local_bucketing: LocalBucketing,
+        self,
+        sdk_key: str,
+        options: DevCycleLocalOptions,
+        local_bucketing: LocalBucketing,
     ):
         super().__init__()
 
@@ -90,8 +90,8 @@ def _get_config(self, last_modified: Optional[float] = None):
                 self._sse_manager.update(self._config)
 
             if (
-                    trigger_on_client_initialized
-                    and self._options.on_client_initialized is not None
+                trigger_on_client_initialized
+                and self._options.on_client_initialized is not None
             ):
                 try:
                     self._options.on_client_initialized()
@@ -130,7 +130,11 @@ def sse_message(self, message: ld_eventsource.actions.Event):
         logger.info(f"DevCycle: Received message: {message.data}")
         sse_message = json.loads(message.data)
         dvc_data = json.loads(sse_message.get("data"))
-        if dvc_data.get("type") == "refetchConfig" or dvc_data.get("type") == "" or dvc_data.get("type") is None:
+        if (
+            dvc_data.get("type") == "refetchConfig"
+            or dvc_data.get("type") == ""
+            or dvc_data.get("type") is None
+        ):
             logger.info("DevCycle: Received refetchConfig message - updating config")
             self._get_config(dvc_data["lastModified"])
 

devcycle_python_sdk/managers/sse_manager.py

@@ -6,22 +6,29 @@
 
 
 class SSEManager:
-    def __init__(self, handlestate: callable(ld_eventsource.actions.Start),
-                 handleerror: callable(ld_eventsource.actions.Fault),
-                 handlemessage: callable(ld_eventsource.actions.Event)):
+    def __init__(
+        self,
+        handlestate: callable(ld_eventsource.actions.Start),
+        handleerror: callable(ld_eventsource.actions.Fault),
+        handlemessage: callable(ld_eventsource.actions.Event),
+    ):
         self.client: ld_eventsource.SSEClient = None
         self.url = ""
         self.handlestate = handlestate
         self.handleerror = handleerror
         self.handlemessage = handlemessage
 
-        self.read_thread = threading.Thread(target=self.read_events,
-                                            args=(self.handlestate, self.handleerror, self.handlemessage))
+        self.read_thread = threading.Thread(
+            target=self.read_events,
+            args=(self.handlestate, self.handleerror, self.handlemessage),
+        )
 
-    def read_events(self,
-                    handlestate: callable(ld_eventsource.actions.Start),
-                    handleerror: callable(ld_eventsource.actions.Fault),
-                    handlemessage: callable(ld_eventsource.actions.Event)):
+    def read_events(
+        self,
+        handlestate: callable(ld_eventsource.actions.Start),
+        handleerror: callable(ld_eventsource.actions.Fault),
+        handlemessage: callable(ld_eventsource.actions.Event),
+    ):
         self.client.start()
         for event in self.client.all:
             if isinstance(event, ld_eventsource.actions.Start):
@@ -32,8 +39,8 @@ def read_events(self,
                 handlemessage(event)
 
     def update(self, config: dict):
-        if self.use_new_config(config['sse']):
-            self.url = config['sse']['hostname'] + config['sse']['path']
+        if self.use_new_config(config["sse"]):
+            self.url = config["sse"]["hostname"] + config["sse"]["path"]
             if self.client is not None:
                 self.client.close()
             if self.read_thread.is_alive():
@@ -42,12 +49,14 @@ def update(self, config: dict):
                 connect=ld_eventsource.config.ConnectStrategy.http(self.url),
                 error_strategy=ld_eventsource.config.ErrorStrategy.CONTINUE,
             )
-            self.read_thread = threading.Thread(target=self.read_events,
-                                                args=(self.handlestate, self.handleerror, self.handlemessage))
+            self.read_thread = threading.Thread(
+                target=self.read_events,
+                args=(self.handlestate, self.handleerror, self.handlemessage),
+            )
             self.read_thread.start()
 
     def use_new_config(self, config: dict) -> bool:
-        new_url = config['hostname'] + config['path']
+        new_url = config["hostname"] + config["path"]
         if self.url == "" or self.url is None and new_url != "":
             return True
         return self.url != new_url