(ctx context.Context, taskID string)
| 3886 | } |
| 3887 | |
| 3888 | func (m *Service) taskReference(ctx context.Context, taskID string) (Reference, error) { |
| 3889 | record, err := m.store.GetTask(ctx, taskID) |
| 3890 | if err != nil { |
| 3891 | return Reference{}, err |
| 3892 | } |
| 3893 | dependencies, err := m.store.ListDependencies(ctx, record.ID) |
| 3894 | if err != nil { |
| 3895 | return Reference{}, err |
| 3896 | } |
| 3897 | runs, err := m.store.ListTaskRuns(ctx, RunQuery{TaskID: record.ID}) |
| 3898 | if err != nil { |
| 3899 | return Reference{}, err |
| 3900 | } |
| 3901 | status, err := m.canonicalTaskStatus(ctx, record, dependencies, runs) |
| 3902 | if err != nil { |
| 3903 | return Reference{}, err |
| 3904 | } |
| 3905 | reference := taskReferenceFromTask(record, status) |
| 3906 | if err := m.applyEffectivePauseToReference(ctx, &reference); err != nil { |
| 3907 | return Reference{}, err |
| 3908 | } |
| 3909 | return reference, nil |
| 3910 | } |
| 3911 | |
| 3912 | func taskReferenceFromTask(record Task, status Status) Reference { |
| 3913 | return Reference{ |
no test coverage detected