chore: codefmt

Author: KKould

src/query/service/src/interpreters/interpreter_task_alter.rs

@@ -18,7 +18,7 @@ use databend_common_exception::Result;
 use databend_common_sql::plans::AlterTaskPlan;
 
 use crate::interpreters::task::TaskInterpreter;
-use crate::interpreters::task::TaskInterpreterFactory;
+use crate::interpreters::task::TaskInterpreterManager;
 use crate::interpreters::Interpreter;
 use crate::pipelines::PipelineBuildResult;
 use crate::sessions::QueryContext;
@@ -50,7 +50,7 @@ impl Interpreter for AlterTaskInterpreter {
     #[fastrace::trace]
     #[async_backtrace::framed]
     async fn execute2(&self) -> Result<PipelineBuildResult> {
-        TaskInterpreterFactory::build(&self.ctx)?
+        TaskInterpreterManager::build(&self.ctx)?
             .alter_task(&self.ctx, &self.plan)
             .await?;
 

src/query/service/src/interpreters/interpreter_task_create.rs

@@ -18,7 +18,7 @@ use databend_common_exception::Result;
 use databend_common_sql::plans::CreateTaskPlan;
 
 use crate::interpreters::task::TaskInterpreter;
-use crate::interpreters::task::TaskInterpreterFactory;
+use crate::interpreters::task::TaskInterpreterManager;
 use crate::interpreters::Interpreter;
 use crate::pipelines::PipelineBuildResult;
 use crate::sessions::QueryContext;
@@ -48,7 +48,7 @@ impl Interpreter for CreateTaskInterpreter {
     #[fastrace::trace]
     #[async_backtrace::framed]
     async fn execute2(&self) -> Result<PipelineBuildResult> {
-        TaskInterpreterFactory::build(&self.ctx)?
+        TaskInterpreterManager::build(&self.ctx)?
             .create_task(&self.ctx, &self.plan)
             .await?;
 

src/query/service/src/interpreters/interpreter_task_describe.rs

@@ -19,7 +19,7 @@ use databend_common_sql::plans::DescribeTaskPlan;
 use databend_common_storages_system::parse_tasks_to_datablock;
 
 use crate::interpreters::task::TaskInterpreter;
-use crate::interpreters::task::TaskInterpreterFactory;
+use crate::interpreters::task::TaskInterpreterManager;
 use crate::interpreters::Interpreter;
 use crate::pipelines::PipelineBuildResult;
 use crate::sessions::QueryContext;
@@ -49,7 +49,7 @@ impl Interpreter for DescribeTaskInterpreter {
     #[fastrace::trace]
     #[async_backtrace::framed]
     async fn execute2(&self) -> Result<PipelineBuildResult> {
-        let Some(task) = TaskInterpreterFactory::build(&self.ctx)?
+        let Some(task) = TaskInterpreterManager::build(&self.ctx)?
             .describe_task(&self.ctx, &self.plan)
             .await?
         else {

src/query/service/src/interpreters/interpreter_task_drop.rs

@@ -18,7 +18,7 @@ use databend_common_exception::Result;
 use databend_common_sql::plans::DropTaskPlan;
 
 use crate::interpreters::task::TaskInterpreter;
-use crate::interpreters::task::TaskInterpreterFactory;
+use crate::interpreters::task::TaskInterpreterManager;
 use crate::interpreters::Interpreter;
 use crate::pipelines::PipelineBuildResult;
 use crate::sessions::QueryContext;
@@ -48,7 +48,7 @@ impl Interpreter for DropTaskInterpreter {
     #[fastrace::trace]
     #[async_backtrace::framed]
     async fn execute2(&self) -> Result<PipelineBuildResult> {
-        TaskInterpreterFactory::build(&self.ctx)?
+        TaskInterpreterManager::build(&self.ctx)?
             .drop_task(&self.ctx, &self.plan)
             .await?;
 

src/query/service/src/interpreters/interpreter_task_execute.rs

@@ -18,7 +18,7 @@ use databend_common_exception::Result;
 use databend_common_sql::plans::ExecuteTaskPlan;
 
 use crate::interpreters::task::TaskInterpreter;
-use crate::interpreters::task::TaskInterpreterFactory;
+use crate::interpreters::task::TaskInterpreterManager;
 use crate::interpreters::Interpreter;
 use crate::pipelines::PipelineBuildResult;
 use crate::sessions::QueryContext;
@@ -48,7 +48,7 @@ impl Interpreter for ExecuteTaskInterpreter {
     #[fastrace::trace]
     #[async_backtrace::framed]
     async fn execute2(&self) -> Result<PipelineBuildResult> {
-        TaskInterpreterFactory::build(&self.ctx)?
+        TaskInterpreterManager::build(&self.ctx)?
             .execute_task(&self.ctx, &self.plan)
             .await?;
 

src/query/service/src/interpreters/interpreter_tasks_show.rs

@@ -19,7 +19,7 @@ use databend_common_sql::plans::ShowTasksPlan;
 use databend_common_storages_system::parse_tasks_to_datablock;
 
 use crate::interpreters::task::TaskInterpreter;
-use crate::interpreters::task::TaskInterpreterFactory;
+use crate::interpreters::task::TaskInterpreterManager;
 use crate::interpreters::Interpreter;
 use crate::pipelines::PipelineBuildResult;
 use crate::sessions::QueryContext;
@@ -51,7 +51,7 @@ impl Interpreter for ShowTasksInterpreter {
     #[fastrace::trace]
     #[async_backtrace::framed]
     async fn execute2(&self) -> Result<PipelineBuildResult> {
-        let tasks = TaskInterpreterFactory::build(&self.ctx)?
+        let tasks = TaskInterpreterManager::build(&self.ctx)?
             .show_tasks(&self.ctx, &self.plan)
             .await?;
 

src/query/service/src/interpreters/task/mod.rs

@@ -34,9 +34,9 @@ use crate::sessions::QueryContext;
 mod cloud;
 mod private;
 
-pub(crate) struct TaskInterpreterFactory;
+pub(crate) struct TaskInterpreterManager;
 
-impl TaskInterpreterFactory {
+impl TaskInterpreterManager {
     pub fn build(ctx: &QueryContext) -> Result<TaskInterpreterImpl> {
         if GlobalConfig::instance().task.on {
             LicenseManagerSwitch::instance().check_enterprise_enabled(

src/query/service/src/task/service.rs

@@ -23,7 +23,6 @@ use std::time::Duration;
 
 use async_stream::stream;
 use chrono::DateTime;
-use chrono::Local;
 use chrono::Utc;
 use chrono_tz::Tz;
 use cron::Schedule;