Function listRunsCmd

internal/app/list.go:811–905

(args []string)

}

func listRunsCmd(args []string) int {
	fs := flagSet("list runs")
	status := fs.String("status", "", "backlog|in-progress|done")
	includeArchived := fs.Bool("include-archived", false, "include archived")
	opts := addListFlags(fs)
	if err := fs.Parse(args); err != nil {
		return 2
	}
	fmtKind, err := listfmt.ParseFormat(*opts.format)
	if err != nil {
		fmt.Fprintf(os.Stderr, "error: %v\n", err)
		return 2
	}
	var playbookSlug string
	if fs.NArg() > 0 {
		playbookSlug = fs.Arg(0)
	}

	dbPath, err := flowDBPath()
	if err != nil {
		fmt.Fprintf(os.Stderr, "error: %v\n", err)
		return 1
	}
	db, err := flowdb.OpenDB(dbPath)
	if err != nil {
		fmt.Fprintf(os.Stderr, "error: %v\n", err)
		return 1
	}
	defer db.Close()

	tasks, err := flowdb.ListTasks(db, flowdb.TaskFilter{
		Kind:            "playbook_run",
		PlaybookSlug:    playbookSlug,
		Status:          *status,
		IncludeArchived: *includeArchived,
	})
	if err != nil {
		fmt.Fprintf(os.Stderr, "error: %v\n", err)
		return 1
	}

	headers := []string{"STATUS", "SLUG", "PLAYBOOK", "NOTES"}
	tsvHeaders := []string{"slug", "status", "playbook", "archived"}
	if len(tasks) == 0 {
		return emptyResult(fmtKind, "runs", tsvHeaders)
	}

	type runRow struct {
		Slug     string `json:"slug"`
		Status   string `json:"status"`
		Playbook string `json:"playbook,omitempty"`
		Archived bool   `json:"archived,omitempty"`
	}
	rows := make([]runRow, len(tasks))
	for i, tk := range tasks {
		r := runRow{Slug: tk.Slug, Status: tk.Status, Archived: tk.ArchivedAt.Valid}
		if tk.PlaybookSlug.Valid {
			r.Playbook = tk.PlaybookSlug.String