lint

Author: Tymek

tests/integration_tests/integration_unleash.py

@@ -1,6 +1,6 @@
 # ---
-import os
 import logging
+import os
 import sys
 import time
 
@@ -16,17 +16,21 @@
 root.addHandler(handler)
 # ---
 
-api_url = os.getenv('UNLEASH_API_URL', 'https://app.unleash-hosted.com/demo/api')
-api_token = os.getenv('UNLEASH_API_TOKEN', 'demo-app:dev.9fc74dd72d2b88bea5253c04240b21a54841f08d9918046ed55a06b5')
+api_url = os.getenv("UNLEASH_API_URL", "https://app.unleash-hosted.com/demo/api")
+api_token = os.getenv(
+    "UNLEASH_API_TOKEN",
+    "demo-app:dev.9fc74dd72d2b88bea5253c04240b21a54841f08d9918046ed55a06b5",
+)
 flag = "example-flag"
 use_streaming = os.getenv("USE_STREAMING", "true").lower() == "true"
 
 client = UnleashClient(
     url=api_url,
     app_name="integration-python",
-    custom_headers={'Authorization': api_token},
+    custom_headers={"Authorization": api_token},
     experimental_mode={"type": "streaming"} if use_streaming else None,
-    metrics_interval=1)
+    metrics_interval=1,
+)
 
 client.initialize_client()
 

tests/unit_tests/streaming/test_event_processor.py

@@ -1,9 +1,5 @@
 from __future__ import annotations
 
-import json
-
-import pytest
-
 from UnleashClient.streaming.event_processor import StreamingEventProcessor
 
 

tests/unit_tests/streaming/test_streaming_connector.py

@@ -1,12 +1,8 @@
 from __future__ import annotations
 
-import json
 import threading
 import time
 from typing import Iterable
-from unittest.mock import MagicMock, patch
-
-import pytest
 
 from UnleashClient.streaming import StreamingConnector
 from UnleashClient.streaming.event_processor import StreamingEventProcessor
@@ -63,6 +59,7 @@ def close(self):
     def interrupt(self):
         self.close()
 
+
 def test_successful_connection_calls_ready():
     engine = FakeEngine()
     processor = StreamingEventProcessor(engine)