| 976 | } |
| 977 | |
| 978 | func taskRunPayloadFromRun(run *taskpkg.Run) apicontract.TaskRunPayload { |
| 979 | if run == nil { |
| 980 | return apicontract.TaskRunPayload{} |
| 981 | } |
| 982 | |
| 983 | return apicontract.TaskRunPayload{ |
| 984 | ID: run.ID, |
| 985 | TaskID: run.TaskID, |
| 986 | Status: run.Status, |
| 987 | Attempt: run.Attempt, |
| 988 | ClaimedBy: cloneActorIdentity(run.ClaimedBy), |
| 989 | SessionID: run.SessionID, |
| 990 | Origin: run.Origin, |
| 991 | IdempotencyKey: run.IdempotencyKey, |
| 992 | NetworkChannel: run.NetworkChannel, |
| 993 | QueuedAt: run.QueuedAt, |
| 994 | ClaimedAt: optionalTime(run.ClaimedAt), |
| 995 | StartedAt: optionalTime(run.StartedAt), |
| 996 | EndedAt: optionalTime(run.EndedAt), |
| 997 | Error: run.Error, |
| 998 | Metadata: cloneRawMessage(run.Metadata), |
| 999 | Result: cloneRawMessage(run.Result), |
| 1000 | } |
| 1001 | } |
| 1002 | |
| 1003 | func taskReferencePayloadFromReference(record taskpkg.Reference) apicontract.TaskReferencePayload { |
| 1004 | return apicontract.TaskReferencePayload{ |