fix test error

Author: fanng

src/query/service/tests/it/storages/fuse/operations/mutation/block_compact_mutator.rs

@@ -96,7 +96,8 @@ async fn do_compact(ctx: Arc<QueryContext>, table: Arc<dyn Table>) -> Result<boo
         .await?
     {
         pipeline.set_max_threads(settings.get_max_threads()? as usize);
-        let executor_settings = ExecutorSettings::try_create(&settings)?;
+        let query_id = ctx.get_id();
+        let executor_settings = ExecutorSettings::try_create(&settings, query_id)?;
         let executor = PipelineCompleteExecutor::try_create(pipeline, executor_settings)?;
         ctx.set_executor(Arc::downgrade(&executor.get_inner()));
         executor.execute()?;

src/query/service/tests/it/storages/fuse/operations/mutation/deletion_mutator.rs

@@ -104,7 +104,8 @@ pub async fn do_deletion(
         .await?;
     if !pipeline.pipes.is_empty() {
         pipeline.set_max_threads(settings.get_max_threads()? as usize);
-        let executor_settings = ExecutorSettings::try_create(&settings)?;
+        let query_id = ctx.get_id();
+        let executor_settings = ExecutorSettings::try_create(&settings, query_id)?;
         let executor = PipelineCompleteExecutor::try_create(pipeline, executor_settings)?;
         ctx.set_executor(Arc::downgrade(&executor.get_inner()));
         executor.execute()?;

src/query/service/tests/it/storages/fuse/table_test_fixture.rs

@@ -424,7 +424,8 @@ pub async fn execute_query(ctx: Arc<QueryContext>, query: &str) -> Result<Sendab
 }
 
 pub fn execute_pipeline(ctx: Arc<QueryContext>, mut res: PipelineBuildResult) -> Result<()> {
-    let executor_settings = ExecutorSettings::try_create(&ctx.get_settings())?;
+    let query_id = ctx.get_id();
+    let executor_settings = ExecutorSettings::try_create(&ctx.get_settings(), query_id)?;
     res.set_max_threads(ctx.get_settings().get_max_threads()? as usize);
     let mut pipelines = res.sources_pipelines;
     pipelines.push(res.main_pipeline);