[ci] apply automatic fixes

feldera-bot · igorscs · commit e283d90a3245 · 2026-02-12T16:52:13.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
diff --git a/python/feldera/rest/feldera_client.py b/python/feldera/rest/feldera_client.py
@@ -232,17 +232,17 @@ def __wait_for_pipeline_state(
             )
             time.sleep(0.1)
 
-    def __wait_for_pipeline_state_one_of(
-        self,
-        pipeline_name: str,
-        states: list[str],
-        timeout_s: float | None = None,
-        start: bool = True,
-        ignore_deployment_error: bool = False,
-    ) -> PipelineStatus:
-        start_time = time.monotonic()
-        poll_interval_s = 0.1
-        states = [state.lower() for state in states]
+    def __wait_for_pipeline_state_one_of(
+        self,
+        pipeline_name: str,
+        states: list[str],
+        timeout_s: float | None = None,
+        start: bool = True,
+        ignore_deployment_error: bool = False,
+    ) -> PipelineStatus:
+        start_time = time.monotonic()
+        poll_interval_s = 0.1
+        states = [state.lower() for state in states]
 
         while True:
             if timeout_s is not None:
@@ -258,29 +258,29 @@ def __wait_for_pipeline_state_one_of(
 
             if status.lower() in states:
                 return PipelineStatus.from_str(status)
-            elif (
-                status == "Stopped"
-                and len(resp.deployment_error or {}) > 0
-                and resp.deployment_desired_status == "Stopped"
-            ):
-                if ignore_deployment_error:
-                    logging.debug(
-                        "ignoring stopped deployment error while waiting for %s to start: %s",
-                        pipeline_name,
-                        (resp.deployment_error or {}).get("message", ""),
-                    )
-                    time.sleep(poll_interval_s)
-                    continue
-                err_msg = "Unable to START the pipeline:\n" if start else ""
-                raise RuntimeError(
-                    f"""{err_msg}Unable to transition the pipeline to one of the states: {states}.
-Reason: The pipeline is in a STOPPED state due to the following error:
-{resp.deployment_error.get("message", "")}"""
+            elif (
+                status == "Stopped"
+                and len(resp.deployment_error or {}) > 0
+                and resp.deployment_desired_status == "Stopped"
+            ):
+                if ignore_deployment_error:
+                    logging.debug(
+                        "ignoring stopped deployment error while waiting for %s to start: %s",
+                        pipeline_name,
+                        (resp.deployment_error or {}).get("message", ""),
+                    )
+                    time.sleep(poll_interval_s)
+                    continue
+                err_msg = "Unable to START the pipeline:\n" if start else ""
+                raise RuntimeError(
+                    f"""{err_msg}Unable to transition the pipeline to one of the states: {states}.
+Reason: The pipeline is in a STOPPED state due to the following error:
+{resp.deployment_error.get("message", "")}"""
                 )
-            logging.debug(
-                "still starting %s, waiting for 100 more milliseconds", pipeline_name
-            )
-            time.sleep(poll_interval_s)
+            logging.debug(
+                "still starting %s, waiting for 100 more milliseconds", pipeline_name
+            )
+            time.sleep(poll_interval_s)
 
     def create_pipeline(self, pipeline: Pipeline, wait: bool = True) -> Pipeline:
         """
@@ -447,26 +447,26 @@ def activate_pipeline(
             pipeline_name, ["running", "AwaitingApproval"], timeout_s
         )
 
-    def _inner_start_pipeline(
-        self,
-        pipeline_name: str,
-        initial: str = "running",
-        bootstrap_policy: Optional[BootstrapPolicy] = None,
-        wait: bool = True,
-        timeout_s: Optional[float] = None,
-        ignore_deployment_error: bool = False,
-    ) -> Optional[PipelineStatus]:
+    def _inner_start_pipeline(
+        self,
+        pipeline_name: str,
+        initial: str = "running",
+        bootstrap_policy: Optional[BootstrapPolicy] = None,
+        wait: bool = True,
+        timeout_s: Optional[float] = None,
+        ignore_deployment_error: bool = False,
+    ) -> Optional[PipelineStatus]:
         """
 
         :param pipeline_name: The name of the pipeline to start
         :param initial: The initial state to start the pipeline in. "running"
             by default.
-        :param wait: Set True to wait for the pipeline to start. True by default
-        :param timeout_s: The amount of time in seconds to wait for the
-            pipeline to start.
-        :param ignore_deployment_error: Set True to ignore deployment errors while waiting for
-            START transition. If `timeout_s` is not provided, a default timeout is
-            used to avoid indefinite waiting.
+        :param wait: Set True to wait for the pipeline to start. True by default
+        :param timeout_s: The amount of time in seconds to wait for the
+            pipeline to start.
+        :param ignore_deployment_error: Set True to ignore deployment errors while waiting for
+            START transition. If `timeout_s` is not provided, a default timeout is
+            used to avoid indefinite waiting.
         """
 
         params = {"initial": initial}
@@ -478,54 +478,54 @@ def _inner_start_pipeline(
             params=params,
         )
 
-        if not wait:
-            return None
-
-        effective_timeout_s = timeout_s
-        if ignore_deployment_error and effective_timeout_s is None:
-            # ignore_deployment_error can intentionally skip the stopped+error failure guard.
-            # Bound the wait so callers don't get an unbounded polling loop.
-            effective_timeout_s = 60.0
-            logging.warning(
-                "start_pipeline(ignore_deployment_error=True) called without timeout; "
-                "defaulting to %.0fs",
-                effective_timeout_s,
-            )
-
-        return self.__wait_for_pipeline_state_one_of(
-            pipeline_name,
-            [initial, "AwaitingApproval"],
-            effective_timeout_s,
-            ignore_deployment_error=ignore_deployment_error,
-        )
-
-    def start_pipeline(
-        self,
-        pipeline_name: str,
-        bootstrap_policy: Optional[BootstrapPolicy] = None,
-        wait: bool = True,
-        timeout_s: Optional[float] = None,
-        ignore_deployment_error: bool = False,
-    ) -> Optional[PipelineStatus]:
+        if not wait:
+            return None
+
+        effective_timeout_s = timeout_s
+        if ignore_deployment_error and effective_timeout_s is None:
+            # ignore_deployment_error can intentionally skip the stopped+error failure guard.
+            # Bound the wait so callers don't get an unbounded polling loop.
+            effective_timeout_s = 60.0
+            logging.warning(
+                "start_pipeline(ignore_deployment_error=True) called without timeout; "
+                "defaulting to %.0fs",
+                effective_timeout_s,
+            )
+
+        return self.__wait_for_pipeline_state_one_of(
+            pipeline_name,
+            [initial, "AwaitingApproval"],
+            effective_timeout_s,
+            ignore_deployment_error=ignore_deployment_error,
+        )
+
+    def start_pipeline(
+        self,
+        pipeline_name: str,
+        bootstrap_policy: Optional[BootstrapPolicy] = None,
+        wait: bool = True,
+        timeout_s: Optional[float] = None,
+        ignore_deployment_error: bool = False,
+    ) -> Optional[PipelineStatus]:
         """
 
         :param pipeline_name: The name of the pipeline to start
-        :param wait: Set True to wait for the pipeline to start.
-            True by default
-        :param timeout_s: The amount of time in seconds to wait for the
-            pipeline to start.
-        :param ignore_deployment_error: Set True to ignore deployment errors while waiting
-            for START transition.
-        """
-
-        return self._inner_start_pipeline(
-            pipeline_name,
-            "running",
-            bootstrap_policy,
-            wait,
-            timeout_s,
-            ignore_deployment_error,
-        )
+        :param wait: Set True to wait for the pipeline to start.
+            True by default
+        :param timeout_s: The amount of time in seconds to wait for the
+            pipeline to start.
+        :param ignore_deployment_error: Set True to ignore deployment errors while waiting
+            for START transition.
+        """
+
+        return self._inner_start_pipeline(
+            pipeline_name,
+            "running",
+            bootstrap_policy,
+            wait,
+            timeout_s,
+            ignore_deployment_error,
+        )
 
     def start_pipeline_as_paused(
         self,
