Function fetchLocalExperiments

pkg/cli/experiments_command.go:482–526

fetchLocalExperiments lists experiment branches and reads their state from the local git repo.

()

// fetchLocalExperiments lists experiment branches and reads their state from the local git repo.
func fetchLocalExperiments() ([]ExperimentInfo, error) {
	experimentsLog.Print("Fetching local experiment branches via git for-each-ref")

	cmd := exec.Command("git", "for-each-ref",
		"--sort=-committerdate",
		"--format=%(refname:short)",
		"refs/remotes/origin/"+experimentsBranchPrefix+"*",
		"refs/heads/"+experimentsBranchPrefix+"*",
	)
	output, err := cmd.Output()
	if err != nil {
		var exitErr *exec.ExitError
		if errors.As(err, &exitErr) && exitErr.ExitCode() == 128 {
			return []ExperimentInfo{}, nil
		}
		return nil, fmt.Errorf("failed to list experiment branches: %w", err)
	}

	seen := make(map[string]struct {
	})
	var experiments []ExperimentInfo

	for line := range strings.SplitSeq(strings.TrimSpace(string(output)), "\n") {
		if line == "" {
			continue
		}
		workflowID := extractExperimentName(line)
		if workflowID == "" || setutil.Contains(seen, workflowID) {
			continue
		}
		seen[workflowID] = struct {
		}{}

		branchName := experimentsBranchPrefix + workflowID
		// Prefer remote ref; fall back to local.
		ref := "origin/" + branchName
		if !gitRefExists(ref) {
			ref = branchName
		}
		state := readLocalExperimentState(ref)
		experiments = append(experiments, experimentInfoFromState(workflowID, branchName, state))
	}

	return experiments, nil
}

// fetchRemoteExperiments lists experiment branches and reads their state via the GitHub API.
func fetchRemoteExperiments(repoOverride string) ([]ExperimentInfo, error) {