| 785 | } |
| 786 | |
| 787 | func failTaskRunFromRequest(req apicontract.FailTaskRunRequest) (taskpkg.RunFailure, error) { |
| 788 | failure := taskpkg.RunFailure{ |
| 789 | Error: strings.TrimSpace(req.Error), |
| 790 | Metadata: cloneRawMessage(req.Metadata), |
| 791 | } |
| 792 | if err := failure.Validate("run_failure"); err != nil { |
| 793 | return taskpkg.RunFailure{}, invalidParamsRPCError(err) |
| 794 | } |
| 795 | return failure, nil |
| 796 | } |
| 797 | |
| 798 | func cancelTaskRunFromRequest(req apicontract.CancelTaskRunRequest) (taskpkg.CancelRun, error) { |
| 799 | cancelReq := taskpkg.CancelRun{ |