chore: codefmt

Author: KKould

src/query/service/tests/it/pipelines/udf_transport.rs

@@ -246,7 +246,7 @@ async fn malformed_data_returns_parse_hint() -> Result<()> {
 async fn schema_mismatch_returns_schema_hint() -> Result<()> {
     let message = run_mock_exchange(MockMode::SchemaMismatch).await?;
     assert!(
-        message.contains("returned an unexpected schema"),
+        message.contains("return incorrect type"),
         "unexpected schema mismatch message: {message}"
     );
     Ok(())

src/query/service/tests/it/sql/exec/get_table_bind_test.rs

@@ -39,22 +39,25 @@ use databend_common_catalog::runtime_filter_info::RuntimeFilterReport;
 use databend_common_catalog::session_type::SessionType;
 use databend_common_catalog::statistics::data_cache_statistics::DataCacheMetrics;
 use databend_common_catalog::table::Table;
+use databend_common_catalog::table_args::TableArgs;
 use databend_common_catalog::table_context::ContextError;
 use databend_common_catalog::table_context::FilteredCopyFiles;
 use databend_common_catalog::table_context::ProcessInfo;
 use databend_common_catalog::table_context::StageAttachment;
 use databend_common_catalog::table_context::TableContext;
+use databend_common_catalog::table_function::TableFunction;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::BlockThresholds;
 use databend_common_expression::Expr;
 use databend_common_expression::FunctionContext;
 use databend_common_expression::Scalar;
 use databend_common_io::prelude::FormatSettings;
-use databend_common_meta_app::principal::{FileFormatParams, UDTFServer};
+use databend_common_meta_app::principal::FileFormatParams;
 use databend_common_meta_app::principal::GrantObject;
 use databend_common_meta_app::principal::OnErrorMode;
 use databend_common_meta_app::principal::RoleInfo;
+use databend_common_meta_app::principal::UDTFServer;
 use databend_common_meta_app::principal::UserDefinedConnection;
 use databend_common_meta_app::principal::UserInfo;
 use databend_common_meta_app::principal::UserPrivilegeType;
@@ -159,8 +162,6 @@ use databend_storages_common_table_meta::meta::TableSnapshot;
 use parking_lot::Mutex;
 use parking_lot::RwLock;
 use xorf::BinaryFuse16;
-use databend_common_catalog::table_args::TableArgs;
-use databend_common_catalog::table_function::TableFunction;
 
 type MetaType = (String, String, String);
 
@@ -491,7 +492,13 @@ impl Catalog for FakedCatalog {
         todo!()
     }
 
-    fn transform_udtf_as_table_function(&self, ctx: &dyn TableContext, table_args: &TableArgs, udtf: UDTFServer, func_name: &str) -> Result<Arc<dyn TableFunction>> {
+    fn transform_udtf_as_table_function(
+        &self,
+        _ctx: &dyn TableContext,
+        _table_args: &TableArgs,
+        _udtf: UDTFServer,
+        _func_name: &str,
+    ) -> Result<Arc<dyn TableFunction>> {
         todo!()
     }
 }

src/query/service/tests/it/storages/fuse/operations/commit.rs

@@ -37,11 +37,13 @@ use databend_common_catalog::runtime_filter_info::RuntimeFilterReady;
 use databend_common_catalog::runtime_filter_info::RuntimeFilterReport;
 use databend_common_catalog::statistics::data_cache_statistics::DataCacheMetrics;
 use databend_common_catalog::table::Table;
+use databend_common_catalog::table_args::TableArgs;
 use databend_common_catalog::table_context::ContextError;
 use databend_common_catalog::table_context::FilteredCopyFiles;
 use databend_common_catalog::table_context::ProcessInfo;
 use databend_common_catalog::table_context::StageAttachment;
 use databend_common_catalog::table_context::TableContext;
+use databend_common_catalog::table_function::TableFunction;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
 use databend_common_expression::BlockThresholds;
@@ -50,10 +52,11 @@ use databend_common_expression::Expr;
 use databend_common_expression::FunctionContext;
 use databend_common_expression::Scalar;
 use databend_common_io::prelude::FormatSettings;
-use databend_common_meta_app::principal::{FileFormatParams, UDTFServer};
+use databend_common_meta_app::principal::FileFormatParams;
 use databend_common_meta_app::principal::GrantObject;
 use databend_common_meta_app::principal::OnErrorMode;
 use databend_common_meta_app::principal::RoleInfo;
+use databend_common_meta_app::principal::UDTFServer;
 use databend_common_meta_app::principal::UserDefinedConnection;
 use databend_common_meta_app::principal::UserInfo;
 use databend_common_meta_app::principal::UserPrivilegeType;
@@ -164,8 +167,6 @@ use parking_lot::Mutex;
 use parking_lot::RwLock;
 use walkdir::WalkDir;
 use xorf::BinaryFuse16;
-use databend_common_catalog::table_args::TableArgs;
-use databend_common_catalog::table_function::TableFunction;
 
 #[tokio::test(flavor = "multi_thread")]
 async fn test_fuse_occ_retry() -> Result<()> {
@@ -1241,7 +1242,13 @@ impl Catalog for FakedCatalog {
         todo!()
     }
 
-    fn transform_udtf_as_table_function(&self, ctx: &dyn TableContext, table_args: &TableArgs, udtf: UDTFServer, func_name: &str) -> Result<Arc<dyn TableFunction>> {
+    fn transform_udtf_as_table_function(
+        &self,
+        _ctx: &dyn TableContext,
+        _table_args: &TableArgs,
+        _udtf: UDTFServer,
+        _func_name: &str,
+    ) -> Result<Arc<dyn TableFunction>> {
         todo!()
     }
 }