( _ context.Context, release ForceReleaseRunMutation, )
| 1409 | } |
| 1410 | |
| 1411 | func (s *inMemoryManagerStore) ForceReleaseTaskRun( |
| 1412 | _ context.Context, |
| 1413 | release ForceReleaseRunMutation, |
| 1414 | ) (ForceRunMutationResult, error) { |
| 1415 | run, ok := s.runs[strings.TrimSpace(release.RunID)] |
| 1416 | if !ok { |
| 1417 | return ForceRunMutationResult{}, ErrTaskRunNotFound |
| 1418 | } |
| 1419 | if run.Status.Normalize() != TaskRunStatusClaimed { |
| 1420 | return ForceRunMutationResult{}, ErrInvalidStatusTransition |
| 1421 | } |
| 1422 | previous := cloneTaskRun(run) |
| 1423 | run = requeuedTestRun(run) |
| 1424 | s.runs[run.ID] = cloneTaskRun(run) |
| 1425 | return ForceRunMutationResult{Previous: previous, Run: cloneTaskRun(run)}, nil |
| 1426 | } |
| 1427 | |
| 1428 | func (s *inMemoryManagerStore) ForceFailTaskRun( |
| 1429 | _ context.Context, |
nothing calls this directly
no test coverage detected