chore: remove some TODO done

This commit is contained in:
discord9
2024-05-06 15:37:07 +08:00
parent a3417f50cf
commit d7a132a02f
2 changed files with 1 additions and 4 deletions

View File

@@ -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

View File

@@ -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 {})