| 2213 | } |
| 2214 | |
| 2215 | func cancelTaskFromRequest(req contract.CancelTaskRequest) (taskpkg.CancelTask, error) { |
| 2216 | cancelReq := taskpkg.CancelTask{ |
| 2217 | Reason: strings.TrimSpace(req.Reason), |
| 2218 | Metadata: cloneRawMessage(req.Metadata), |
| 2219 | } |
| 2220 | if err := cancelReq.Validate("cancel_task"); err != nil { |
| 2221 | return taskpkg.CancelTask{}, err |
| 2222 | } |
| 2223 | return cancelReq, nil |
| 2224 | } |
| 2225 | |
| 2226 | func addTaskDependencyFromRequest(taskID string, req contract.AddTaskDependencyRequest) (taskpkg.AddDependency, error) { |
| 2227 | kind := req.Kind.Normalize() |