Function inspectNextAction

internal/task/diagnostics.go:263–295

(view *InspectView)

}

func inspectNextAction(view *InspectView) InspectNextAction {
	if view == nil {
		return InspectNextActionWaitingForSession
	}
	if inspectHasRecoveryDiagnostic(view.Diagnostics) {
		return InspectNextActionRecoveryRequired
	}
	if view.CurrentRun == nil {
		if isTerminalTaskStatus(view.Task.Status) {
			return InspectNextActionTerminal
		}
		return InspectNextActionWaitingForSession
	}
	switch view.CurrentRun.Status.Normalize() {
	case TaskRunStatusQueued:
		if inspectHasDiagnostic(view.Diagnostics, diagnosticcontract.CodeTaskRunStranded) {
			return InspectNextActionStranded
		}
		if view.Scheduler.Paused {
			return InspectNextActionWaitingForSession
		}
		if view.SessionCatalogPresent && view.EligibleSessionCount > 0 {
			return InspectNextActionClaimAvailable
		}
		return InspectNextActionWaitingForSession
	case TaskRunStatusClaimed, TaskRunStatusStarting, TaskRunStatusRunning:
		return InspectNextActionRunning
	case TaskRunStatusCompleted, TaskRunStatusFailed, TaskRunStatusCanceled:
		return InspectNextActionTerminal
	default:
		return InspectNextActionWaitingForSession
	}
}

func inspectHasRecoveryDiagnostic(items []diagnosticcontract.DiagnosticItem) bool {
	for _, code := range []string{