( ctx context.Context, taskID string, actor ActorIdentity, )
| 1041 | } |
| 1042 | |
| 1043 | func (m *Service) loadTaskTriageState( |
| 1044 | ctx context.Context, |
| 1045 | taskID string, |
| 1046 | actor ActorIdentity, |
| 1047 | ) (TriageState, error) { |
| 1048 | state, err := m.store.GetTaskTriageState(ctx, taskID, actor) |
| 1049 | if err == nil { |
| 1050 | return state, nil |
| 1051 | } |
| 1052 | if errors.Is(err, ErrTaskTriageStateNotFound) { |
| 1053 | return TriageState{TaskID: taskID, Actor: actor}, nil |
| 1054 | } |
| 1055 | return TriageState{}, err |
| 1056 | } |
| 1057 | |
| 1058 | func (m *Service) loadCancellationTree(ctx context.Context, taskID string) ([]Task, Task, error) { |
| 1059 | tree, err := m.collectTaskTree(ctx, taskID) |
no test coverage detected