Method UpdateTask

internal/task/manager.go:463–518

UpdateTask applies one mutable patch while preserving immutable identity and structural fields under manager control.

(ctx context.Context, id string, patch Patch, actor ActorContext)

// UpdateTask applies one mutable patch while preserving immutable identity and
// structural fields under manager control.
func (m *Service) UpdateTask(ctx context.Context, id string, patch Patch, actor ActorContext) (*Task, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return nil, err
	}

	trimmedID := strings.TrimSpace(id)
	if trimmedID == "" {
		return nil, fmt.Errorf("%w: task id is required", ErrValidation)
	}
	normalizedPatch, err := normalizeTaskPatch(patch)
	if err != nil {
		return nil, err
	}
	if normalizedPatch.NetworkChannel != nil {
		if err := m.validateNetworkChannel("task_patch.network_channel", *normalizedPatch.NetworkChannel); err != nil {
			return nil, err
		}
	}

	current, err := m.store.GetTask(ctx, trimmedID)
	if err != nil {
		return nil, err
	}

	updated, changedFields := applyTaskPatch(current, normalizedPatch)
	if len(changedFields) == 0 {
		return &current, nil
	}

	dependencies, err := m.store.ListDependencies(ctx, trimmedID)
	if err != nil {
		return nil, err
	}
	runs, err := m.store.ListTaskRuns(ctx, RunQuery{TaskID: trimmedID})
	if err != nil {
		return nil, err
	}

	canonicalStatus, err := m.canonicalTaskStatus(ctx, updated, dependencies, runs)
	if err != nil {
		return nil, err
	}
	updated.Status = canonicalStatus
	updated.UpdatedAt = m.now().UTC()
	if err := m.store.UpdateTask(ctx, updated); err != nil {
		return nil, err
	}
	if err := m.recordTaskEvent(ctx, updated.ID, "", taskEventUpdated, actor, updatedTaskPayload{
		ChangedFields: append([]string(nil), changedFields...),
		Status:        updated.Status,
	}); err != nil {
		return nil, err
	}

	return &updated, nil
}

// CancelTask propagates manager-owned cancellation through the target task,