[ci] apply automatic fixes

feldera-bot · abhizer · commit ebd90b45ee51 · 2025-10-15T04:48:25.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
@@ -14,7 +14,7 @@ def __init__(
         pipeline_name: str,
         view_name: str,
         callback: Callable[[pd.DataFrame, int], None],
-        exception_callback: Callable[[BaseException], None]
+        exception_callback: Callable[[BaseException], None],
     ):
         super().__init__()
         self.daemon = True
diff --git a/python/feldera/output_handler.py b/python/feldera/output_handler.py
@@ -34,8 +34,11 @@ def exception_callback(exception: BaseException):
 
         # sets up the callback runner
         self.handler = CallbackRunner(
-            self.client, self.pipeline_name, self.view_name, callback,
-            exception_callback
+            self.client,
+            self.pipeline_name,
+            self.view_name,
+            callback,
+            exception_callback,
         )
 
     def start(self):
diff --git a/python/feldera/pipeline.py b/python/feldera/pipeline.py
@@ -269,7 +269,9 @@ def foreach_chunk(
         if self.status() not in [PipelineStatus.RUNNING, PipelineStatus.PAUSED]:
             raise RuntimeError("Pipeline must be running or paused to listen to output")
 
-        handler = CallbackRunner(self.client, self.name, view_name, callback, lambda exception: None)
+        handler = CallbackRunner(
+            self.client, self.name, view_name, callback, lambda exception: None
+        )
         handler.start()
 
     def wait_for_completion(
