We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e26b525 commit a1111afCopy full SHA for a1111af
numaflow/src/sink.rs
@@ -131,7 +131,7 @@ pub struct Response {
131
pub id: String,
132
/// response_type indicates the type of the response.
133
pub response_type: ResponseType,
134
- /// err string is used to describe the error if [`Response::success`] was `false`.
+ /// err string is used to describe the error if [`ResponseType::Failure`] is set.
135
pub err: Option<String>,
136
pub serve_response: Option<Vec<u8>>,
137
}
@@ -259,7 +259,6 @@ where
259
grpc_resp_tx.clone(),
260
)
261
.await?;
262
- println!("Time taken for batch: {:?}", start.elapsed().as_micros());
263
264
Ok(())
265
0 commit comments