Method cancelOpenTaskRuns

internal/task/manager.go:1140–1163

(
	ctx context.Context,
	record Task,
	runs []Run,
	req CancelTask,
	actor ActorContext,
	propagatedFromTaskID string,
)

}

func (m *Service) cancelOpenTaskRuns(
	ctx context.Context,
	record Task,
	runs []Run,
	req CancelTask,
	actor ActorContext,
	propagatedFromTaskID string,
) ([]string, error) {
	cancelledRunIDs := make([]string, 0)
	for _, run := range runs {
		if isTerminalRunStatus(run.Status) {
			continue
		}
		cancelledRun, err := m.cancelRunRecord(ctx, record, run, CancelRun(req), actor, cancelRunOptions{
			propagatedFromTaskID: propagatedFromTaskID,
			reconcileTask:        false,
		})
		if err != nil {
			return nil, err
		}
		cancelledRunIDs = append(cancelledRunIDs, cancelledRun.ID)
	}
	return cancelledRunIDs, nil
}

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