Function fetchWorkflowRuns

pkg/cli/health_command.go:174–228

fetchWorkflowRuns fetches workflow runs from GitHub for the specified time period

(workflowName, startDate, repoOverride string, verbose bool)

// fetchWorkflowRuns fetches workflow runs from GitHub for the specified time period
func fetchWorkflowRuns(workflowName, startDate, repoOverride string, verbose bool) ([]WorkflowRun, error) {
	healthLog.Printf("Fetching workflow runs: workflow=%s, startDate=%s", workflowName, startDate)

	opts := ListWorkflowRunsOptions{
		WorkflowName: workflowName,
		StartDate:    startDate,
		Limit:        100,
		RepoOverride: repoOverride,
		Verbose:      verbose,
	}

	allRuns := make([]WorkflowRun, 0)

	// Fetch runs in batches
	for i := range MaxIterations {
		runs, totalCount, err := listWorkflowRunsWithPagination(opts)
		if err != nil {
			return nil, err
		}

		if len(runs) == 0 {
			break
		}

		// Accumulate runs; duration calculation is done here since the GitHub API
		// does not return a pre-computed duration field.
		for _, run := range runs {
			if run.Duration == 0 && !run.StartedAt.IsZero() && !run.UpdatedAt.IsZero() {
				run.Duration = run.UpdatedAt.Sub(run.StartedAt)
			}
			allRuns = append(allRuns, run)
		}

		healthLog.Printf("Fetched batch %d: got %d runs, total agentic runs so far: %d", i+1, len(runs), len(allRuns))

		// If we got fewer runs than requested, we've reached the end
		if len(runs) < opts.Limit {
			break
		}

		// Update pagination for next batch
		if len(runs) > 0 {
			lastRun := runs[len(runs)-1]
			opts.BeforeDate = lastRun.CreatedAt.Format(time.RFC3339)
		}

		// Avoid fetching more than necessary
		if totalCount > 0 && len(allRuns) >= totalCount {
			break
		}
	}

	healthLog.Printf("Total workflow runs fetched: %d", len(allRuns))
	return allRuns, nil
}

// displayHealthSummary displays a summary of health metrics for all workflows
func displayHealthSummary(runs []WorkflowRun, config HealthConfig) error {