diff --git a/src/query/catalog/src/table.rs b/src/query/catalog/src/table.rs
index 067c6a45eec7..a47a4671ad97 100644
--- a/src/query/catalog/src/table.rs
+++ b/src/query/catalog/src/table.rs
@@ -226,11 +226,7 @@ pub trait Table: Sync + Send {
     ) -> Result<Option<Pipeline>> {
         let (_, _, _) = (table_ctx, plan, source_pipeline);
 
-        Err(ErrorCode::Unimplemented(format!(
-            "The 'build_prune_pipeline' operation is not implemented for the table '{}'. Table engine type: '{}'.",
-            self.name(),
-            self.get_table_info().meta.engine
-        )))
+        Ok(None)
     }
 
     /// Assembly the pipeline of appending data to storage
diff --git a/src/query/service/src/pipelines/builders/builder_scan.rs b/src/query/service/src/pipelines/builders/builder_scan.rs
index b2624f6c5ef5..2df8c19e1200 100644
--- a/src/query/service/src/pipelines/builders/builder_scan.rs
+++ b/src/query/service/src/pipelines/builders/builder_scan.rs
@@ -43,9 +43,7 @@ impl PipelineBuilder {
         self.ctx.set_partitions(scan.source.parts.clone())?;
         self.ctx
             .set_wait_runtime_filter(scan.scan_id, self.contain_sink_processor);
-        if self.ctx.get_settings().get_enable_prune_pipeline()?
-            && table.get_table_info().meta.engine == *"FUSE"
-        {
+        if self.ctx.get_settings().get_enable_prune_pipeline()? {
             if let Some(prune_pipeline) = table.build_prune_pipeline(
                 self.ctx.clone(),
                 &scan.source,