[ci] apply automatic fixes

feldera-bot · Karakatiza666 · commit 2f31d70b69e0 · 2025-09-20T22:04:51.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
diff --git a/demo/all-packaged/run.py b/demo/all-packaged/run.py
@@ -23,7 +23,7 @@
 def main():
     # Initialize OIDC token cache before any API calls (reuses pytest logic)
     setup_token_cache()
-    
+
     # Parse command-line arguments
     parser = argparse.ArgumentParser()
     parser.add_argument(
@@ -34,7 +34,7 @@ def main():
     # Create Feldera client using the API URL with OIDC token caching support
     api_url = args.api_url
     print(f"Feldera API URL: {api_url}")
-    
+
     # Get effective API key (OIDC token takes precedence over static API key)
     # This reuses the same token caching infrastructure as the Python test suite
     effective_api_key = _get_effective_api_key()
@@ -50,7 +50,7 @@ def main():
     headers = {"Accept": "application/json"}
     if effective_api_key:
         headers["Authorization"] = f"Bearer {effective_api_key}"
-    
+
     demos = requests.get(f"{api_url}/v0/config/demos", headers=headers).json()
     print(f"Total {len(demos)} packages demos were found and will be run")
     for demo in demos:
diff --git a/python/feldera/testutils_oidc.py b/python/feldera/testutils_oidc.py
@@ -197,6 +197,7 @@ def parse_cached_token(env_token: str) -> Optional[Dict[str, Any]]:
     """
     try:
         import base64
+
         token_json = base64.b64decode(env_token.encode()).decode()
         token_data = json.loads(token_json)
         return token_data
@@ -240,11 +241,14 @@ def encode_token_for_env(token_data: Dict[str, Any]) -> str:
         Base64-encoded JSON string suitable for environment variable storage
     """
     import base64
+
     token_json = json.dumps(token_data)
     return base64.b64encode(token_json.encode()).decode()
 
 
-def get_cached_token_from_env(env_var_name: str = "FELDERA_PYTEST_OIDC_TOKEN") -> Optional[Dict[str, Any]]:
+def get_cached_token_from_env(
+    env_var_name: str = "FELDERA_PYTEST_OIDC_TOKEN",
+) -> Optional[Dict[str, Any]]:
     """
     Retrieve and validate cached token from environment variable.
 
diff --git a/python/tests/platform/conftest.py b/python/tests/platform/conftest.py
@@ -6,21 +6,19 @@
 """
 
 import pytest
-import os
 
 
 def is_master(config) -> bool:
     """True if the code running is in the xdist master node or not using xdist at all."""
     return not hasattr(config, "workerinput")
 
 
-
-
 def pytest_configure(config):
     """Configure hook: fetch OIDC token on master node only."""
     if is_master(config):
         # This runs only on the master node (or in single-node mode)
         from feldera.testutils_oidc import setup_token_cache
+
         token_data = setup_token_cache()
         if token_data:
             print("🔐 AUTH: Master node cached OIDC token for distribution to workers")
@@ -46,7 +44,7 @@ def oidc_token_fixture(request):
     in environment variables for cross-process access.
     """
     from feldera.testutils_oidc import get_cached_token_from_env
-    
+
     # Token is accessed via environment variable - this fixture just verifies setup
     token_data = get_cached_token_from_env()
     if token_data:
