From 25a45032853e970d5d672130cfdee7e5f975f3ca Mon Sep 17 00:00:00 2001 From: junxiang Mu <1948535941@qq.com> Date: Fri, 25 Jul 2025 08:18:14 +0800 Subject: [PATCH] fix: fmt Signed-off-by: junxiang Mu <1948535941@qq.com> --- crates/s3select-query/src/instance.rs | 2 +- crates/s3select-query/src/lib.rs | 9 +++++---- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/crates/s3select-query/src/instance.rs b/crates/s3select-query/src/instance.rs index 2523e9f6d..3ecac61c7 100644 --- a/crates/s3select-query/src/instance.rs +++ b/crates/s3select-query/src/instance.rs @@ -108,7 +108,7 @@ pub async fn make_rustfsms(input: Arc, is_test: bool) } pub async fn make_rustfsms_with_components( - input: Arc, + input: Arc, is_test: bool, func_manager: Arc, parser: Arc, diff --git a/crates/s3select-query/src/lib.rs b/crates/s3select-query/src/lib.rs index 9f1686da9..4fab1772a 100644 --- a/crates/s3select-query/src/lib.rs +++ b/crates/s3select-query/src/lib.rs @@ -20,9 +20,9 @@ pub mod instance; pub mod metadata; pub mod sql; -use std::sync::{Arc, LazyLock}; use rustfs_s3select_api::{QueryResult, server::dbms::DatabaseManagerSystem}; use s3s::dto::SelectObjectContentInput; +use std::sync::{Arc, LazyLock}; use crate::{ execution::{factory::SqlQueryExecutionFactory, scheduler::local::LocalScheduler}, @@ -46,7 +46,7 @@ static GLOBAL_COMPONENTS: LazyLock = LazyLock::new(|| { let scheduler = Arc::new(LocalScheduler {}); let query_execution_factory = Arc::new(SqlQueryExecutionFactory::new(optimizer, scheduler)); let default_table_provider = Arc::new(BaseTableProvider::default()); - + GlobalComponents { func_manager, parser, @@ -68,8 +68,9 @@ pub async fn get_global_db( components.parser.clone(), components.query_execution_factory.clone(), components.default_table_provider.clone(), - ).await?; - + ) + .await?; + Ok(Arc::new(db) as Arc) }