Method List

app/controlplane/pkg/data/workflowrun.go:435–530

List the runs in an organization, optionally filtered out by workflow

(ctx context.Context, orgID uuid.UUID, filters *biz.RunListFilters, p *pagination.CursorOptions)

// List the runs in an organization, optionally filtered out by workflow
func (r *WorkflowRunRepo) List(ctx context.Context, orgID uuid.UUID, filters *biz.RunListFilters, p *pagination.CursorOptions) (result []*biz.WorkflowRun, cursor string, err error) {
	ctx, span := otelx.Start(ctx, workflowRunRepoTracer, "WorkflowRunRepo.List")
	defer span.End()

	if p == nil {
		return nil, "", errors.New("pagination options is required")
	}

	// Org-scoped query uses the denormalized organization_id column for a
	// sargable range scan via the (organization_id, created_at DESC) index.
	// The prior HasWorkflowWith form compiled to a correlated EXISTS that
	// let the planner pick a bad ORDER BY created_at DESC plan. The
	// deleted_at filter still goes via the workflows edge: it's a per-row
	// PK lookup applied after the index narrows the candidate set, so it
	// doesn't reintroduce the planner ambiguity.
	wfPredicates := []predicate.Workflow{workflow.DeletedAtIsNil()}
	if filters != nil && filters.ProjectIDs != nil {
		wfPredicates = append(wfPredicates, workflow.ProjectIDIn(filters.ProjectIDs...))
	}

	q := r.data.DB.WorkflowRun.Query().
		Where(
			workflowrun.OrganizationID(orgID),
			workflowrun.HasWorkflowWith(wfPredicates...),
		).
		Order(ent.Desc(workflowrun.FieldCreatedAt)).
		WithWorkflowAndProject().WithVersion().
		Limit(p.Limit + 1)

	// Append the workflow filter if present
	if filters != nil && filters.WorkflowID != nil {
		q = q.Where(workflowrun.HasWorkflowWith(workflow.ID(*filters.WorkflowID)))
	}

	// Append the state filter if present, i.e only running
	if filters != nil && filters.Status != "" {
		q = q.Where(workflowrun.StateEQ(filters.Status))
	}

	// or the project version
	if filters != nil && filters.VersionID != nil {
		q = q.Where(workflowrun.VersionID(*filters.VersionID))
	}

	// Canonical policy status filter takes precedence over the legacy
	// violations-only filter. Only one is applied to avoid contradictory
	// predicates when a client sends both.
	switch {
	case filters != nil && filters.PolicyStatus != nil:
		entStatus, err := policyStatusToEnt(*filters.PolicyStatus)
		if err != nil {
			return nil, "", err
		}
		q = q.Where(workflowrun.PolicyStatusEQ(entStatus))
	case filters != nil && filters.PolicyViolationsFilter != nil:
		if *filters.PolicyViolationsFilter {
			q = q.Where(workflowrun.HasPolicyViolations(true))
		} else {