[ci] apply automatic fixes

feldera-bot · ryzhyk · commit 99e2ac8f1b80 · 2025-09-20T07:03:03.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
diff --git a/python/feldera/_callback_runner.py b/python/feldera/_callback_runner.py
@@ -39,7 +39,9 @@ def run(self):
         :meta private:
         """
 
-        pipeline = self.client.get_pipeline(self.pipeline_name, PipelineFieldSelector.ALL)
+        pipeline = self.client.get_pipeline(
+            self.pipeline_name, PipelineFieldSelector.ALL
+        )
 
         schemas = pipeline.tables + pipeline.views
         for schema in schemas:
diff --git a/python/feldera/enums.py b/python/feldera/enums.py
@@ -1,6 +1,7 @@
 from enum import Enum
 from typing import Optional
 
+
 class CompilationProfile(Enum):
     """
     The compilation profile to use when compiling the program.
@@ -336,9 +337,10 @@ def from_str(value):
             f"Unknown value '{value}' for enum {FaultToleranceModel.__name__}"
         )
 
+
 class PipelineFieldSelector(Enum):
     ALL = "all"
     """Select all fields of a pipeline."""
 
     STATUS = "status"
-    """Select only the fields required to know the status of a pipeline."""
+    """Select only the fields required to know the status of a pipeline."""
diff --git a/python/feldera/pipeline_builder.py b/python/feldera/pipeline_builder.py
@@ -60,7 +60,10 @@ def create(self) -> Pipeline:
             raise ValueError("Name and SQL are required to create a pipeline")
 
         try:
-            if self.client.get_pipeline(self.name, PipelineFieldSelector.STATUS) is not None:
+            if (
+                self.client.get_pipeline(self.name, PipelineFieldSelector.STATUS)
+                is not None
+            ):
                 raise RuntimeError(f"Pipeline with name {self.name} already exists")
         except FelderaAPIError as err:
             if err.error_code != "UnknownPipelineName":
diff --git a/python/feldera/rest/feldera_client.py b/python/feldera/rest/feldera_client.py
@@ -94,15 +94,19 @@ def localhost(port: int = 8080) -> "FelderaClient":
 
         return FelderaClient(f"http://127.0.0.1:{port}")
 
-    def get_pipeline(self, pipeline_name: str, field_selector: PipelineFieldSelector) -> Pipeline:
+    def get_pipeline(
+        self, pipeline_name: str, field_selector: PipelineFieldSelector
+    ) -> Pipeline:
         """
         Get a pipeline by name
 
         :param pipeline_name: The name of the pipeline
         :param field_selector: Choose what pipeline information to refresh; see PipelineFieldSelector enum definition.
         """
 
-        resp = self.http.get(f"/pipelines/{pipeline_name}?selector={field_selector.value}")
+        resp = self.http.get(
+            f"/pipelines/{pipeline_name}?selector={field_selector.value}"
+        )
 
         return Pipeline.from_dict(resp)
 
@@ -506,7 +510,9 @@ def stop_pipeline(
         start = time.monotonic()
 
         while time.monotonic() - start < timeout_s:
-            status = self.get_pipeline(pipeline_name, PipelineFieldSelector.STATUS).deployment_status
+            status = self.get_pipeline(
+                pipeline_name, PipelineFieldSelector.STATUS
+            ).deployment_status
 
             if status == "Stopped":
                 return
@@ -540,7 +546,9 @@ def clear_storage(self, pipeline_name: str, timeout_s: Optional[float] = 300):
         start = time.monotonic()
 
         while time.monotonic() - start < timeout_s:
-            status = self.get_pipeline(pipeline_name, PipelineFieldSelector.STATUS).storage_status
+            status = self.get_pipeline(
+                pipeline_name, PipelineFieldSelector.STATUS
+            ).storage_status
 
             if status == "Cleared":
                 return
diff --git a/python/tests/platform/test_pipeline_lifecycle.py b/python/tests/platform/test_pipeline_lifecycle.py
@@ -319,7 +319,9 @@ def test_pipeline_clear(pipeline_name):
     assert first.status_code == HTTPStatus.ACCEPTED
     second = clear_pipeline(pipeline_name, wait=True)
     assert second.status_code == HTTPStatus.ACCEPTED
-    assert get_pipeline(pipeline_name, "status").json().get("storage_status") == "Cleared"
+    assert (
+        get_pipeline(pipeline_name, "status").json().get("storage_status") == "Cleared"
+    )
 
 
 @gen_pipeline_name
diff --git a/python/tests/platform/test_shared_pipeline.py b/python/tests/platform/test_shared_pipeline.py
@@ -586,7 +586,9 @@ def test_pipeline_resource_config(self):
         resources = Resources(config)
         self.pipeline.set_runtime_config(RuntimeConfig(resources=resources))
         self.pipeline.start()
-        got = TEST_CLIENT.get_pipeline(self.pipeline.name, PipelineFieldSelector.ALL).runtime_config["resources"]
+        got = TEST_CLIENT.get_pipeline(
+            self.pipeline.name, PipelineFieldSelector.ALL
+        ).runtime_config["resources"]
         assert got == config
 
     def test_support_bundle(self):
