(
ddb_repo: Data<DDBRepository>,
task_identifier: Path<TaskIdentifier>,
completion_request: Json<TaskCompletionRequest>
)
| 159 | |
| 160 | #[put("/task/{task_global_id}/complete")] |
| 161 | pub async fn complete_task( |
| 162 | ddb_repo: Data<DDBRepository>, |
| 163 | task_identifier: Path<TaskIdentifier>, |
| 164 | completion_request: Json<TaskCompletionRequest> |
| 165 | ) -> Result<Json<TaskIdentifier>, TaskError> { |
| 166 | state_transition( |
| 167 | ddb_repo, |
| 168 | task_identifier.into_inner().task_global_id, |
| 169 | TaskState::Completed, |
| 170 | Some(completion_request.result_file.clone()) |
| 171 | ).await |
| 172 | } |
nothing calls this directly
no test coverage detected