[ci] apply automatic fixes

feldera-bot · ryzhyk · commit 66515743bd1b · 2026-04-02T01:26:05.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
diff --git a/python/feldera/testutils.py b/python/feldera/testutils.py
@@ -347,7 +347,11 @@ def number_of_processed_records(pipeline: Pipeline) -> int:
 
 
 def run_workload(
-    pipeline_name: str, tables: dict, views: List[ViewSpec], transaction: bool = True, stop: bool = True
+    pipeline_name: str,
+    tables: dict,
+    views: List[ViewSpec],
+    transaction: bool = True,
+    stop: bool = True,
 ) -> Pipeline:
     """
     Helper to run a pipeline to completion and validate the views afterwards using ad-hoc queries.
diff --git a/python/tests/workloads/test_tpch.py b/python/tests/workloads/test_tpch.py
@@ -1429,19 +1429,39 @@ def tpch_test(config: TPCHTestConfig):
 
     elif config.mode == "transaction":
         pipeline = run_workload(
-            unique_pipeline_name("tpc-h-transaction"), tables, views, transaction=True, stop=False
+            unique_pipeline_name("tpc-h-transaction"),
+            tables,
+            views,
+            transaction=True,
+            stop=False,
         )
-        count = next(pipeline.query("SELECT COUNT(*) as cnt FROM REGION WHERE R_COMMENT IS NOT NULL"))["cnt"]
+        count = next(
+            pipeline.query(
+                "SELECT COUNT(*) as cnt FROM REGION WHERE R_COMMENT IS NOT NULL"
+            )
+        )["cnt"]
         if count != 0:
-            raise RuntimeError(f"REGION.R_COMMENT is not NULL despite 'skip_unused_columns' = 'true': {count}")
+            raise RuntimeError(
+                f"REGION.R_COMMENT is not NULL despite 'skip_unused_columns' = 'true': {count}"
+            )
         pipeline.stop(force=True)
     elif config.mode == "stream":
         pipeline = run_workload(
-            unique_pipeline_name("tpc-h-stream"), tables, views, transaction=False, stop=False
+            unique_pipeline_name("tpc-h-stream"),
+            tables,
+            views,
+            transaction=False,
+            stop=False,
         )
-        count = next(pipeline.query("SELECT COUNT(*) as cnt FROM REGION WHERE R_COMMENT IS NOT NULL"))["cnt"]
+        count = next(
+            pipeline.query(
+                "SELECT COUNT(*) as cnt FROM REGION WHERE R_COMMENT IS NOT NULL"
+            )
+        )["cnt"]
         if count != 0:
-            raise RuntimeError(f"REGION.R_COMMENT is not NULL despite 'skip_unused_columns' = 'true': {count}")
+            raise RuntimeError(
+                f"REGION.R_COMMENT is not NULL despite 'skip_unused_columns' = 'true': {count}"
+            )
         pipeline.stop(force=True)
     else:
         raise RuntimeError(f"Unknown mode: {config.mode}")
