(
&self,
task: &ExecutionTask,
error_code: impl Into<ErrorCode>,
)
| 55 | } |
| 56 | |
| 57 | pub(in crate::data::executor) fn response_error( |
| 58 | &self, |
| 59 | task: &ExecutionTask, |
| 60 | error_code: impl Into<ErrorCode>, |
| 61 | ) -> Response { |
| 62 | Response { |
| 63 | request_id: task.request_id(), |
| 64 | status: Status::Error, |
| 65 | attempt: 1, |
| 66 | partial: false, |
| 67 | payload: Payload::empty(), |
| 68 | watermark_lsn: self.watermark, |
| 69 | error_code: Some(error_code.into()), |
| 70 | } |
| 71 | } |
| 72 | |
| 73 | /// Build the map key for the four vector in-memory maps |
| 74 | /// (`vector_collections`, `vector_params`, `index_configs`, `ivf_indexes`). |
no test coverage detected