(
&self,
task: &ExecutionTask,
payload: Vec<u8>,
)
| 39 | } |
| 40 | |
| 41 | pub(in crate::data::executor) fn response_partial( |
| 42 | &self, |
| 43 | task: &ExecutionTask, |
| 44 | payload: Vec<u8>, |
| 45 | ) -> Response { |
| 46 | Response { |
| 47 | request_id: task.request_id(), |
| 48 | status: Status::Partial, |
| 49 | attempt: 1, |
| 50 | partial: true, |
| 51 | payload: Payload::from_vec(payload), |
| 52 | watermark_lsn: self.watermark, |
| 53 | error_code: None, |
| 54 | } |
| 55 | } |
| 56 | |
| 57 | pub(in crate::data::executor) fn response_error( |
| 58 | &self, |
no test coverage detected