Method PauseTask

internal/task/scheduler_controls.go:82–131

PauseTask marks one task as paused for future scheduler and claim eligibility.

(
	ctx context.Context,
	id string,
	req PauseTaskRequest,
	actor ActorContext,
)

// PauseTask marks one task as paused for future scheduler and claim eligibility.
func (m *Service) PauseTask(
	ctx context.Context,
	id string,
	req PauseTaskRequest,
	actor ActorContext,
) (*Task, error) {
	if err := m.requireForceRunAuthority(actor); err != nil {
		return nil, err
	}
	normalized, err := normalizePauseTaskRequest(req)
	if err != nil {
		return nil, err
	}
	pauseStore, err := m.requireTaskPauseStore()
	if err != nil {
		return nil, err
	}
	taskID := strings.TrimSpace(id)
	previous, err := m.store.GetTask(ctx, taskID)
	if err != nil {
		return nil, err
	}
	if isTerminalTaskStatus(previous.Status) {
		return nil, terminalTaskPauseError(previous)
	}
	if err := m.requireForceRunRate(actor, previous.ID); err != nil {
		return nil, err
	}
	updated, err := pauseStore.PauseTask(ctx, PauseMutation{
		TaskID:   previous.ID,
		Actor:    actorLabel(actor),
		Reason:   normalized.Reason,
		PausedAt: m.now().UTC(),
	})
	if err != nil {
		return nil, err
	}
	if err := m.recordTaskEvent(ctx, updated.ID, "", taskEventPaused, actor, taskPausePayload{
		Manual:         true,
		ActorKind:      actor.Actor.Kind.Normalize(),
		ActorID:        actor.Actor.Ref,
		PreviousPaused: previous.Paused,
		Paused:         updated.Paused,
		Reason:         normalized.Reason,
		Metadata:       cloneRawJSON(normalized.Metadata),
	}); err != nil {
		return nil, err
	}
	return &updated, nil
}

// ResumeTask clears one task pause for future scheduler and claim eligibility.
func (m *Service) ResumeTask(