[ci] apply automatic fixes

feldera-bot · gz · commit f204af24ac40 · 2025-08-22T18:20:26.000Z
Signed-off-by: feldera-bot &lt;feldera-bot@feldera.com&gt;
Signed-off-by: Gerd Zellweger &lt;mail@gerdzellweger.com&gt;
diff --git a/crates/adapters/src/adhoc/executor.rs b/crates/adapters/src/adhoc/executor.rs
@@ -10,7 +10,6 @@ use bytestring::ByteString;
 use datafusion::common::{DataFusionError, Result as DFResult};
 use datafusion::dataframe::DataFrame;
 use datafusion::execution::SendableRecordBatchStream;
-use datafusion::logical_expr::SortExpr;
 use datafusion::prelude::col;
 use feldera_storage::tokio::TOKIO;
 use feldera_types::query::MAX_WS_FRAME_SIZE;
diff --git a/openapi.json b/openapi.json
@@ -4768,7 +4768,8 @@
           "text",
           "json",
           "parquet",
-          "arrow_ipc"
+          "arrow_ipc",
+          "hash"
         ]
       },
       "AdhocQueryArgs": {
diff --git a/python/feldera/rest/feldera_client.py b/python/feldera/rest/feldera_client.py
@@ -895,9 +895,7 @@ def query_as_text(
             if chunk:
                 yield chunk.decode("utf-8")
 
-    def query_as_hash(
-        self, pipeline_name: str, query: str
-    ) -> str:
+    def query_as_hash(self, pipeline_name: str, query: str) -> str:
         """
         Executes an ad-hoc query on the specified pipeline and returns a hash of the result.
 
@@ -918,7 +916,6 @@ def query_as_hash(
         )
         return resp
 
-
     def query_as_parquet(self, pipeline_name: str, query: str, path: str):
         """
         Executes an ad-hoc query on the specified pipeline and saves the result to a parquet file.
diff --git a/python/tests/test_shared_pipeline.py b/python/tests/test_shared_pipeline.py
@@ -91,8 +91,9 @@ def test_adhoc_query_hash(self):
         resp = TEST_CLIENT.query_as_hash(
             self.pipeline.name, "SELECT * FROM tbl ORDER BY id"
         )
-        assert resp == "0B021466CA428474EF16F899D0F841D7338C168C063DA5DB43666D1AB3081558"
-
+        assert (
+            resp == "0B021466CA428474EF16F899D0F841D7338C168C063DA5DB43666D1AB3081558"
+        )
 
     def test_adhoc_query_parquet(self):
         data = "1\n2\n"
