chore: remove dbg

databendlabs · Nov 19, 2024 · 4f6d541 · 4f6d541
1 parent c80b5b1
commit 4f6d541
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/query/storages/fuse/src/operations/read/block_partition_receiver_source.rs b/src/query/storages/fuse/src/operations/read/block_partition_receiver_source.rs
@@ -50,9 +50,9 @@ impl AsyncSource for BlockPartitionReceiverSource {
     #[async_backtrace::framed]
     async fn generate(&mut self) -> Result<Option<DataBlock>> {
         match self.meta_receiver.recv().await {
-            Ok(Ok(part)) => dbg!(Ok(Some(DataBlock::empty_with_meta(
+            Ok(Ok(part)) => Ok(Some(DataBlock::empty_with_meta(
                 BlockPartitionMeta::create(vec![part]),
-            )))),
+            ))),
             Ok(Err(e)) => Err(
                 // The error is occurred in pruning process
                 e,

diff --git a/src/query/storages/fuse/src/pruning_pipeline/send_part_info_sink.rs b/src/query/storages/fuse/src/pruning_pipeline/send_part_info_sink.rs
@@ -77,7 +77,7 @@ impl AsyncSink for SendPartInfoSink {
 
                 for info in info_ptr {
                     if let Some(sender) = &self.sender {
-                        let _ = dbg!(sender.send(Ok(info)).await);
+                        let _ = sender.send(Ok(info)).await;
                     }
                 }