From d7a132a02f4f1491ad9497e102dd2070f68bb5cc Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Mon, 6 May 2024 15:37:07 +0800
Subject: [PATCH] chore: remove some TODO done

---
 src/flow/src/adapter.rs        | 1 -
 src/flow/src/adapter/worker.rs | 4 +---
 2 files changed, 1 insertion(+), 4 deletions(-)

diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs
index 4bfb0d8b17..f29d5333f4 100644
--- a/src/flow/src/adapter.rs
+++ b/src/flow/src/adapter.rs
@@ -532,7 +532,6 @@ pub struct FlowNodeContext {
 }
 
 impl FlowNodeContext {
-    // TODO(discord9): add send_buf in case the broadcast channel is full
     // return number of rows it actuall send(including what's in the buffer)
     pub fn send(&mut self, table_id: TableId, rows: Vec<DiffRow>) -> Result<usize, Error> {
         let sender = self
diff --git a/src/flow/src/adapter/worker.rs b/src/flow/src/adapter/worker.rs
index 9aa238e2a1..ae22fdb5f2 100644
--- a/src/flow/src/adapter/worker.rs
+++ b/src/flow/src/adapter/worker.rs
@@ -161,9 +161,7 @@ impl WorkerHandle {
             Ok(result)
         } else {
             InternalSnafu {
-                reason: format!(
-                    "Flow Node/Worker itc failed, expect Response::Remove, found {ret:?}"
-                ),
+                reason: format!("Flow Node/Worker failed, expect Response::Remove, found {ret:?}"),
             }
             .fail()
             .with_context(|_| EvalSnafu {})