Method cancelTaskTreeRecord

internal/task/manager.go:1086–1112

(
	ctx context.Context,
	rootTaskID string,
	idx int,
	record Task,
	req CancelTask,
	actor ActorContext,
)

}

func (m *Service) cancelTaskTreeRecord(
	ctx context.Context,
	rootTaskID string,
	idx int,
	record Task,
	req CancelTask,
	actor ActorContext,
) (Task, error) {
	runs, status, err := m.loadTaskRuntimeState(ctx, record)
	if err != nil {
		return Task{}, err
	}
	record.Status = status
	if idx > 0 && isTerminalTaskStatus(status) {
		return record, nil
	}

	propagatedFromTaskID := cancellationPropagationRoot(rootTaskID, idx)
	cancelledRunIDs, err := m.cancelOpenTaskRuns(ctx, record, runs, req, actor, propagatedFromTaskID)
	if err != nil {
		return Task{}, err
	}
	if status.Normalize() == TaskStatusCanceled && len(cancelledRunIDs) == 0 {
		return record, nil
	}
	return m.persistCancelledTask(ctx, record, req, actor, propagatedFromTaskID, cancelledRunIDs)
}

func (m *Service) loadTaskRuntimeState(
	ctx context.Context,