(req contract.FailTaskRunRequest)
| 2457 | } |
| 2458 | |
| 2459 | func failTaskRunFromRequest(req contract.FailTaskRunRequest) (taskpkg.RunFailure, error) { |
| 2460 | failure := taskpkg.RunFailure{ |
| 2461 | Error: strings.TrimSpace(req.Error), |
| 2462 | Metadata: cloneRawMessage(req.Metadata), |
| 2463 | } |
| 2464 | if err := failure.Validate("run_failure"); err != nil { |
| 2465 | return taskpkg.RunFailure{}, err |
| 2466 | } |
| 2467 | return failure, nil |
| 2468 | } |
| 2469 | |
| 2470 | func cancelTaskRunFromRequest(req contract.CancelTaskRunRequest) (taskpkg.CancelRun, error) { |
| 2471 | cancelReq := taskpkg.CancelRun{ |