diff --git a/api/tangled/cbor_gen.go b/api/tangled/cbor_gen.go
index 460a49ff..d54e883a 100644
--- a/api/tangled/cbor_gen.go
+++ b/api/tangled/cbor_gen.go
@@ -1203,7 +1203,11 @@ func (t *CiDefs_Workflow) MarshalCBOR(w io.Writer) error {
 	}
 
 	cw := cbg.NewCborWriter(w)
-	fieldCount := 5
+	fieldCount := 6
+
+	if t.Error == nil {
+		fieldCount--
+	}
 
 	if t.FinishedAt == nil {
 		fieldCount--
@@ -1263,6 +1267,38 @@ func (t *CiDefs_Workflow) MarshalCBOR(w io.Writer) error {
 		return err
 	}
 
+	// t.Error (string) (string)
+	if t.Error != nil {
+
+		if len("error") > 1000000 {
+			return xerrors.Errorf("Value in field \"error\" was too long")
+		}
+
+		if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("error"))); err != nil {
+			return err
+		}
+		if _, err := cw.WriteString(string("error")); err != nil {
+			return err
+		}
+
+		if t.Error == nil {
+			if _, err := cw.Write(cbg.CborNull); err != nil {
+				return err
+			}
+		} else {
+			if len(*t.Error) > 1000000 {
+				return xerrors.Errorf("Value in field t.Error was too long")
+			}
+
+			if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(*t.Error))); err != nil {
+				return err
+			}
+			if _, err := cw.WriteString(string(*t.Error)); err != nil {
+				return err
+			}
+		}
+	}
+
 	// t.Status (string) (string)
 	if len("status") > 1000000 {
 		return xerrors.Errorf("Value in field \"status\" was too long")
@@ -1415,6 +1451,27 @@ func (t *CiDefs_Workflow) UnmarshalCBOR(r io.Reader) (err error) {
 
 				t.Name = string(sval)
 			}
+			// t.Error (string) (string)
+		case "error":
+
+			{
+				b, err := cr.ReadByte()
+				if err != nil {
+					return err
+				}
+				if b != cbg.CborNull[0] {
+					if err := cr.UnreadByte(); err != nil {
+						return err
+					}
+
+					sval, err := cbg.ReadStringWithMax(cr, 1000000)
+					if err != nil {
+						return err
+					}
+
+					t.Error = (*string)(&sval)
+				}
+			}
 			// t.Status (string) (string)
 		case "status":
 
diff --git a/api/tangled/cidefs.go b/api/tangled/cidefs.go
index d2360c1a..8edcbe31 100644
--- a/api/tangled/cidefs.go
+++ b/api/tangled/cidefs.go
@@ -74,6 +74,7 @@ func (t *CiDefs_Pipeline_Trigger) UnmarshalJSON(b []byte) error {
 
 // CiDefs_Workflow is a "workflow" in the sh.tangled.ci.defs schema.
 type CiDefs_Workflow struct {
+	Error      *string `json:"error,omitempty" cborgen:"error,omitempty"`
 	FinishedAt *string `json:"finishedAt,omitempty" cborgen:"finishedAt,omitempty"`
 	// id: Spindle-local workflow id. Unique per pipeline, usually same as name.
 	Id string `json:"id" cborgen:"id"`
diff --git a/appview/pages/pages.go b/appview/pages/pages.go
index 54714f5b..f99c12f4 100644
--- a/appview/pages/pages.go
+++ b/appview/pages/pages.go
@@ -242,7 +242,11 @@ func (p *Pages) executePlain(name string, w io.Writer, params any) error {
 		return err
 	}
 
-	return tpl.Execute(w, params)
+	err = tpl.Execute(w, params)
+	if err != nil {
+		p.logger.Error("failed to execute template", "template", name, "err", err)
+	}
+	return err
 }
 
 func (p *Pages) executeLogin(name string, w io.Writer, params any) error {
@@ -251,7 +255,11 @@ func (p *Pages) executeLogin(name string, w io.Writer, params any) error {
 		return err
 	}
 
-	return tpl.ExecuteTemplate(w, "layouts/base", params)
+	err = tpl.ExecuteTemplate(w, "layouts/base", params)
+	if err != nil {
+		p.logger.Error("failed to execute login template", "template", name, "err", err)
+	}
+	return err
 }
 
 func (p *Pages) execute(name string, w io.Writer, params any) error {
@@ -260,7 +268,11 @@ func (p *Pages) execute(name string, w io.Writer, params any) error {
 		return err
 	}
 
-	return tpl.ExecuteTemplate(w, "layouts/base", params)
+	err = tpl.ExecuteTemplate(w, "layouts/base", params)
+	if err != nil {
+		p.logger.Error("failed to execute template", "template", name, "err", err)
+	}
+	return err
 }
 
 func (p *Pages) executeRepo(name string, w io.Writer, params any) error {
@@ -269,7 +281,11 @@ func (p *Pages) executeRepo(name string, w io.Writer, params any) error {
 		return err
 	}
 
-	return tpl.ExecuteTemplate(w, "layouts/base", params)
+	err = tpl.ExecuteTemplate(w, "layouts/base", params)
+	if err != nil {
+		p.logger.Error("failed to execute repo template", "template", name, "err", err)
+	}
+	return err
 }
 
 func (p *Pages) executeProfile(name string, w io.Writer, params any) error {
@@ -278,7 +294,11 @@ func (p *Pages) executeProfile(name string, w io.Writer, params any) error {
 		return err
 	}
 
-	return tpl.ExecuteTemplate(w, "layouts/base", params)
+	err = tpl.ExecuteTemplate(w, "layouts/base", params)
+	if err != nil {
+		p.logger.Error("failed to execute profile template", "template", name, "err", err)
+	}
+	return err
 }
 
 type DollyParams struct {
@@ -891,7 +911,7 @@ type RepoIndexParams struct {
 	EmailToDid       map[string]string
 	VerifiedCommits  commitverify.VerifiedCommits
 	Languages        []types.RepoLanguageDetails
-	Pipelines        map[string]*tangled.CiDefs_Pipeline
+	Pipelines        map[string]types.Pipeline
 	NeedsKnotUpgrade bool
 	KnotUnreachable  bool
 	types.RepoIndexResponse
@@ -960,7 +980,7 @@ type RepoLogParams struct {
 	Active          string
 	EmailToDid      map[string]string
 	VerifiedCommits commitverify.VerifiedCommits
-	Pipelines       map[string]*tangled.CiDefs_Pipeline
+	Pipelines       map[string]types.Pipeline
 
 	types.RepoLogResponse
 }
@@ -975,7 +995,7 @@ type RepoCommitParams struct {
 	RepoInfo   repoinfo.RepoInfo
 	Active     string
 	EmailToDid map[string]string
-	Pipeline   *tangled.CiDefs_Pipeline
+	Pipeline   *types.Pipeline
 	DiffOpts   types.DiffOpts
 
 	// singular because it's always going to be just one
@@ -1376,7 +1396,7 @@ type RepoPullsParams struct {
 	FilterQuery        string
 	BaseFilterQuery    string
 	Stacks             []models.Stack
-	Pipelines          map[string]tangled.CiDefs_Pipeline
+	Pipelines          map[string]types.Pipeline
 	LabelDefs          map[string]*models.LabelDefinition
 	Page               pagination.Page
 	PullCount          int
@@ -1416,7 +1436,7 @@ type RepoSinglePullParams struct {
 	BranchDeleteStatus *models.BranchDeleteStatus
 	MergeCheck         types.MergeCheckResponse
 	ResubmitCheck      ResubmitResult
-	Pipelines          map[string]tangled.CiDefs_Pipeline
+	Pipelines          map[string]types.Pipeline
 	Diff               types.DiffRenderer
 	DiffOpts           types.DiffOpts
 	ActiveRound        int
@@ -1588,7 +1608,7 @@ func (p *Pages) RepoForks(w io.Writer, params RepoForksParams) error {
 type PipelinesParams struct {
 	BaseParams
 	RepoInfo   repoinfo.RepoInfo
-	Pipelines  []*tangled.CiDefs_Pipeline
+	Pipelines  []types.Pipeline
 	Active     string
 	FilterKind string
 	Total      int64
@@ -1642,7 +1662,7 @@ func (p *Pages) WorkflowSymbolOOB(w io.Writer, params WorkflowSymbolOOBParams) e
 type WorkflowParams struct {
 	BaseParams
 	RepoInfo repoinfo.RepoInfo
-	Pipeline *tangled.CiDefs_Pipeline
+	Pipeline types.Pipeline
 	Workflow string
 	LogUrl   string
 	Active   string
diff --git a/appview/pages/templates/repo/index.html b/appview/pages/templates/repo/index.html
index 828e5656..c4988b28 100644
--- a/appview/pages/templates/repo/index.html
+++ b/appview/pages/templates/repo/index.html
@@ -260,9 +260,11 @@
 
         <!-- ci status -->
         {{ $pipeline := index $.Pipelines .Hash.String }}
-        {{ if and $pipeline (gt (len $pipeline.Statuses) 0) }}
-          <div class="inline-block px-1 select-none after:content-['·']"></div>
-          {{ template "repo/pipelines/fragments/pipelineSymbolLong" (dict "RepoInfo" $.RepoInfo "Pipeline" $pipeline) }}
+        {{ if $pipeline }}
+          {{ if gt (len $pipeline.Statuses) 0 }}
+            <div class="inline-block px-1 select-none after:content-['·']"></div>
+            {{ template "repo/pipelines/fragments/pipelineSymbolLong" (dict "RepoInfo" $.RepoInfo "Pipeline" $pipeline) }}
+          {{ end }}
         {{ end }}
       </div>
     </div>
diff --git a/appview/pages/templates/repo/log.html b/appview/pages/templates/repo/log.html
index 232f01be..3e4e8111 100644
--- a/appview/pages/templates/repo/log.html
+++ b/appview/pages/templates/repo/log.html
@@ -73,8 +73,10 @@
                 <!-- ci status -->
                 <span class="text-xs">
                   {{ $pipeline := index $.Pipelines .Hash.String }}
-                  {{ if and $pipeline (gt (len $pipeline.Statuses) 0) }}
-                    {{ template "repo/pipelines/fragments/pipelineSymbolLong" (dict "Pipeline" $pipeline "RepoInfo" $.RepoInfo) }}
+                  {{ if $pipeline }}
+                    {{ if gt (len $pipeline.Statuses) 0 }}
+                      {{ template "repo/pipelines/fragments/pipelineSymbolLong" (dict "Pipeline" $pipeline "RepoInfo" $.RepoInfo) }}
+                    {{ end }}
                   {{ end }}
                 </span>
             </div>
@@ -157,11 +159,13 @@
 
                     <!-- ci status -->
                     {{ $pipeline := index $.Pipelines .Hash.String }}
-                    {{ if and $pipeline (gt (len $pipeline.Statuses) 0) }}
-                      <div class="inline-block px-1 select-none after:content-['·']"></div>
-                      <span class="text-sm">
-                        {{ template "repo/pipelines/fragments/pipelineSymbolLong" (dict "Pipeline" $pipeline "RepoInfo" $.RepoInfo) }}
-                      </span>
+                    {{ if $pipeline }}
+                      {{ if gt (len $pipeline.Statuses) 0 }}
+                        <div class="inline-block px-1 select-none after:content-['·']"></div>
+                        <span class="text-sm">
+                          {{ template "repo/pipelines/fragments/pipelineSymbolLong" (dict "Pipeline" $pipeline "RepoInfo" $.RepoInfo) }}
+                        </span>
+                      {{ end }}
                     {{ end }}
                 </div>
             </div>
diff --git a/appview/pages/templates/repo/pipelines/fragments/pipelineSymbolLong.html b/appview/pages/templates/repo/pipelines/fragments/pipelineSymbolLong.html
index b6e04742..6a08ddd6 100644
--- a/appview/pages/templates/repo/pipelines/fragments/pipelineSymbolLong.html
+++ b/appview/pages/templates/repo/pipelines/fragments/pipelineSymbolLong.html
@@ -1,7 +1,7 @@
 {{ define "repo/pipelines/fragments/pipelineSymbolLong" }}
   {{ $pipeline := .Pipeline }}
   {{ $repoinfo := .RepoInfo }}
-  {{ $popoverId := printf "pipeline-status-%d" $pipeline.Id }}
+  {{ $popoverId := printf "pipeline-status-%s" $pipeline.Id }}
   
   <div class="relative inline-block">
     <button
diff --git a/appview/pipelines/pipelines.go b/appview/pipelines/pipelines.go
index 75be920e..415e3f38 100644
--- a/appview/pipelines/pipelines.go
+++ b/appview/pipelines/pipelines.go
@@ -20,6 +20,7 @@ import (
 	"tangled.org/core/lexutil"
 	"tangled.org/core/orm"
 	"tangled.org/core/rbac"
+	"tangled.org/core/types"
 
 	"github.com/bluesky-social/indigo/atproto/syntax"
 	indigoxrpc "github.com/bluesky-social/indigo/xrpc"
@@ -122,7 +123,7 @@ func (p *Pipelines) Index(w http.ResponseWriter, r *http.Request) {
 
 	// sh.tangled.ci.queryPipelines(repo, kind, limit=30)
 	xrpcc := indigoxrpc.Client{Host: spindleUrl}
-	out, err := tangled.CiQueryPipelines(r.Context(), &xrpcc, nil, "", 1, f.RepoDid)
+	out, err := tangled.CiQueryPipelines(r.Context(), &xrpcc, nil, "", 30, f.RepoDid)
 	if err != nil {
 		l.Error("failed to fetch pipelines", "err", err)
 		p.pages.Pipelines(w, pages.PipelinesParams{
@@ -135,10 +136,15 @@ func (p *Pipelines) Index(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	var pipelines []types.Pipeline
+	for _, pipeline := range out.Pipelines {
+		pipelines = append(pipelines, types.Pipeline{CiDefs_Pipeline: pipeline})
+	}
+
 	p.pages.Pipelines(w, pages.PipelinesParams{
 		BaseParams: pages.BaseParamsFromContext(r.Context()),
 		RepoInfo:   p.repoResolver.GetRepoInfo(r, user),
-		Pipelines:  out.Pipelines,
+		Pipelines:  pipelines,
 		FilterKind: filterKind,
 		Total:      out.Total,
 	})
@@ -212,7 +218,7 @@ func (p *Pipelines) Workflow(w http.ResponseWriter, r *http.Request) {
 	p.pages.Workflow(w, pages.WorkflowParams{
 		BaseParams: pages.BaseParamsFromContext(r.Context()),
 		RepoInfo:   p.repoResolver.GetRepoInfo(r, user),
-		Pipeline:   out,
+		Pipeline:   types.Pipeline{CiDefs_Pipeline: out},
 		Workflow:   workflowName,
 	})
 }
@@ -357,6 +363,8 @@ func (p *Pipelines) Logs(w http.ResponseWriter, r *http.Request) {
 				if err := <-done; !isExpectedClose(err) {
 					l.Error("spindle stream error", "err", err)
 				}
+				msg := websocket.FormatCloseMessage(websocket.CloseNormalClosure, "finished")
+				_ = clientConn.WriteMessage(websocket.CloseMessage, msg)
 				return
 			}
 
diff --git a/appview/pulls/list.go b/appview/pulls/list.go
index dbe0bee5..50925bc8 100644
--- a/appview/pulls/list.go
+++ b/appview/pulls/list.go
@@ -16,6 +16,7 @@ import (
 	"github.com/bluesky-social/indigo/atproto/syntax"
 	indigoxrpc "github.com/bluesky-social/indigo/xrpc"
 	"tangled.org/core/hostutil"
+	"tangled.org/core/types"
 )
 
 func (s *Pulls) RepoPulls(w http.ResponseWriter, r *http.Request) {
@@ -264,8 +265,8 @@ func (s *Pulls) RepoPulls(w http.ResponseWriter, r *http.Request) {
 	}
 
 	// commitId -> latest pipeline
-	pipelines := func(ctx context.Context, shas []string) map[string]tangled.CiDefs_Pipeline {
-		m := make(map[string]tangled.CiDefs_Pipeline)
+	pipelines := func(ctx context.Context, shas []string) map[string]types.Pipeline {
+		m := make(map[string]types.Pipeline)
 		if f.Spindle == "" {
 			return m
 		}
@@ -285,7 +286,7 @@ func (s *Pulls) RepoPulls(w http.ResponseWriter, r *http.Request) {
 			if pipeline == nil {
 				continue
 			}
-			m[pipeline.Commit] = *pipeline
+			m[pipeline.Commit] = types.Pipeline{CiDefs_Pipeline: pipeline}
 		}
 		return m
 	}(r.Context(), shas)
diff --git a/appview/pulls/single.go b/appview/pulls/single.go
index d7d1ad54..3f6e0b57 100644
--- a/appview/pulls/single.go
+++ b/appview/pulls/single.go
@@ -161,8 +161,8 @@ func (s *Pulls) repoPullHelper(w http.ResponseWriter, r *http.Request, interdiff
 	}
 
 	// commitId -> latest pipeline
-	pipelines := func(ctx context.Context) map[string]tangled.CiDefs_Pipeline {
-		m := make(map[string]tangled.CiDefs_Pipeline)
+	pipelines := func(ctx context.Context) map[string]types.Pipeline {
+		m := make(map[string]types.Pipeline)
 		if f.Spindle == "" {
 			return m
 		}
@@ -182,7 +182,7 @@ func (s *Pulls) repoPullHelper(w http.ResponseWriter, r *http.Request, interdiff
 			if pipeline == nil {
 				continue
 			}
-			m[pipeline.Commit] = *pipeline
+			m[pipeline.Commit] = types.Pipeline{CiDefs_Pipeline: pipeline}
 		}
 		return m
 	}(r.Context())
diff --git a/appview/repo/log.go b/appview/repo/log.go
index fb1852b2..9971b57f 100644
--- a/appview/repo/log.go
+++ b/appview/repo/log.go
@@ -254,9 +254,9 @@ func (rp *Repo) Commit(w http.ResponseWriter, r *http.Request) {
 		l.Error("failed to getPipelineStatuses", "err", err)
 		// non-fatal
 	}
-	var pipeline *tangled.CiDefs_Pipeline
+	var pipeline *types.Pipeline
 	if p, ok := pipelines[result.Diff.Commit.This]; ok {
-		pipeline = p
+		pipeline = &p
 	}
 
 	rp.pages.RepoCommit(w, pages.RepoCommitParams{
diff --git a/appview/repo/repo_util.go b/appview/repo/repo_util.go
index 80b791eb..6dc96bae 100644
--- a/appview/repo/repo_util.go
+++ b/appview/repo/repo_util.go
@@ -88,13 +88,13 @@ func balanceIndexItems(commitCount, branchCount, tagCount, fileCount int) (commi
 	return
 }
 
-// fetch pipelines from DB and map by commit sha
+// fetch pipelines from spindle and map by commit sha
 func getPipelineStatuses(
 	ctx context.Context,
 	repo *models.Repo,
 	shas []string,
-) (map[string]*tangled.CiDefs_Pipeline, error) {
-	m := make(map[string]*tangled.CiDefs_Pipeline)
+) (map[string]types.Pipeline, error) {
+	m := make(map[string]types.Pipeline)
 
 	if len(shas) == 0 {
 		return m, nil
@@ -106,7 +106,7 @@ func getPipelineStatuses(
 
 	spindleUrl, err := hostutil.EnsureHttpScheme(repo.Spindle)
 	if err != nil {
-		return m, nil // Don't block repo rendering on bad spindle configuration
+		return m, nil
 	}
 
 	xrpcc := &indigoxrpc.Client{Host: spindleUrl}
@@ -116,7 +116,7 @@ func getPipelineStatuses(
 	}
 
 	for _, p := range out.Pipelines {
-		m[p.Commit] = p
+		m[p.Commit] = types.Pipeline{CiDefs_Pipeline: p}
 	}
 
 	return m, nil
diff --git a/lexicons/ci/defs.json b/lexicons/ci/defs.json
index 0c3c0b09..06a9f8c0 100644
--- a/lexicons/ci/defs.json
+++ b/lexicons/ci/defs.json
@@ -77,6 +77,9 @@
         "finishedAt": {
           "type": "string",
           "format": "datetime"
+        },
+        "error": {
+          "type": "string"
         }
       }
     }
diff --git a/spindle/db/pipelines.go b/spindle/db/pipelines.go
index b0ba5fb3..b6821bb1 100644
--- a/spindle/db/pipelines.go
+++ b/spindle/db/pipelines.go
@@ -162,7 +162,7 @@ func (d *DB) mapToCiDefsPipeline(ctx context.Context, rkey string, created int64
 	var workflows []*tangled.CiDefs_Workflow
 	for _, wf := range raw.Workflows {
 		status := "pending"
-		var startedAt, finishedAt *string
+		var startedAt, finishedAt, wfError *string
 
 		if raw.TriggerMetadata != nil && raw.TriggerMetadata.Repo != nil {
 			wfId := models.WorkflowId{
@@ -177,6 +177,7 @@ func (d *DB) mapToCiDefsPipeline(ctx context.Context, rkey string, created int64
 			if err == nil && wfStatus != nil {
 				status = wfStatus.Status
 				startedAt, finishedAt = d.GetWorkflowTimes(wfId)
+				wfError = wfStatus.Error
 			}
 		}
 
@@ -186,6 +187,7 @@ func (d *DB) mapToCiDefsPipeline(ctx context.Context, rkey string, created int64
 			Status:     status,
 			StartedAt:  startedAt,
 			FinishedAt: finishedAt,
+			Error:      wfError,
 		})
 	}
 
diff --git a/types/pipeline.go b/types/pipeline.go
new file mode 100644
index 00000000..8a10257b
--- /dev/null
+++ b/types/pipeline.go
@@ -0,0 +1,242 @@
+package types
+
+import (
+	"fmt"
+	"strings"
+	"time"
+
+	"tangled.org/core/api/tangled"
+)
+
+type StatusKind string
+
+func (s StatusKind) String() string {
+	return string(s)
+}
+
+func (s StatusKind) IsFinish() bool {
+	switch string(s) {
+	case "failed", "timeout", "cancelled", "success":
+		return true
+	}
+	return false
+}
+
+func (s StatusKind) IsStart() bool {
+	switch string(s) {
+	case "pending", "running":
+		return true
+	}
+	return false
+}
+
+type WorkflowStatus struct {
+	*tangled.CiDefs_Workflow
+	PipelineCreatedAt *string
+}
+
+func (w WorkflowStatus) Latest() WorkflowStatus {
+	return w
+}
+
+func (w WorkflowStatus) Error() string {
+	if w.CiDefs_Workflow == nil || w.CiDefs_Workflow.Error == nil {
+		return ""
+	}
+	return *w.CiDefs_Workflow.Error
+}
+
+func (w WorkflowStatus) Status() StatusKind {
+	if w.CiDefs_Workflow == nil {
+		return ""
+	}
+	return StatusKind(w.CiDefs_Workflow.Status)
+}
+
+func (w WorkflowStatus) TimeTaken() time.Duration {
+	if w.CiDefs_Workflow == nil || w.StartedAt == nil || w.FinishedAt == nil || *w.StartedAt == "" || *w.FinishedAt == "" {
+		return 0
+	}
+	t1, err1 := time.Parse(time.RFC3339, *w.StartedAt)
+	t2, err2 := time.Parse(time.RFC3339, *w.FinishedAt)
+	if err1 == nil && err2 == nil && t2.After(t1) {
+		return t2.Sub(t1)
+	}
+	return 0
+}
+
+func (w WorkflowStatus) Created() time.Time {
+	var timeStr string
+	if w.CiDefs_Workflow != nil && w.StartedAt != nil && *w.StartedAt != "" {
+		timeStr = *w.StartedAt
+	} else if w.CiDefs_Workflow != nil && w.FinishedAt != nil && *w.FinishedAt != "" {
+		timeStr = *w.FinishedAt
+	} else if w.PipelineCreatedAt != nil && *w.PipelineCreatedAt != "" {
+		timeStr = *w.PipelineCreatedAt
+	} else {
+		return time.Time{}
+	}
+
+	t, err := time.Parse(time.RFC3339, timeStr)
+	if err != nil {
+		return time.Time{}
+	}
+	return t
+}
+
+type Trigger struct {
+	*tangled.CiDefs_Pipeline_Trigger
+}
+
+func (t Trigger) IsPush() bool {
+	return t.CiDefs_Pipeline_Trigger != nil && t.CiDefs_Pipeline_Trigger.CiTrigger_Push != nil
+}
+
+func (t Trigger) IsPullRequest() bool {
+	return t.CiDefs_Pipeline_Trigger != nil && t.CiDefs_Pipeline_Trigger.CiTrigger_PullRequest != nil
+}
+
+func (t Trigger) TargetRef() string {
+	if t.CiDefs_Pipeline_Trigger == nil {
+		return ""
+	}
+	if t.CiDefs_Pipeline_Trigger.CiTrigger_Push != nil {
+		ref := t.CiDefs_Pipeline_Trigger.CiTrigger_Push.Ref
+		if strings.HasPrefix(ref, "refs/heads/") {
+			return strings.TrimPrefix(ref, "refs/heads/")
+		}
+		if strings.HasPrefix(ref, "refs/tags/") {
+			return strings.TrimPrefix(ref, "refs/tags/")
+		}
+		return ref
+	}
+	if t.CiDefs_Pipeline_Trigger.CiTrigger_PullRequest != nil {
+		return t.CiDefs_Pipeline_Trigger.CiTrigger_PullRequest.TargetBranch
+	}
+	return ""
+}
+
+func (t Trigger) PRSourceBranch() string {
+	if t.CiDefs_Pipeline_Trigger == nil || t.CiDefs_Pipeline_Trigger.CiTrigger_PullRequest == nil {
+		return ""
+	}
+	sb := t.CiDefs_Pipeline_Trigger.CiTrigger_PullRequest.SourceBranch
+	if sb == nil {
+		return ""
+	}
+	return *sb
+}
+
+type Pipeline struct {
+	*tangled.CiDefs_Pipeline
+}
+
+func (p Pipeline) Valid() bool {
+	return p.CiDefs_Pipeline != nil
+}
+
+func (p Pipeline) Id() string {
+	if p.CiDefs_Pipeline == nil {
+		return ""
+	}
+	return p.CiDefs_Pipeline.Id
+}
+
+func (p Pipeline) Statuses() map[string]WorkflowStatus {
+	m := make(map[string]WorkflowStatus)
+	if p.CiDefs_Pipeline != nil {
+		for _, w := range p.CiDefs_Pipeline.Workflows {
+			m[w.Name] = WorkflowStatus{
+				CiDefs_Workflow:   w,
+				PipelineCreatedAt: p.CreatedAt,
+			}
+		}
+	}
+	return m
+}
+
+func (p Pipeline) Counts() map[string]int {
+	m := make(map[string]int)
+	if p.CiDefs_Pipeline != nil {
+		for _, w := range p.CiDefs_Pipeline.Workflows {
+			m[w.Status]++
+		}
+	}
+	return m
+}
+
+func (p Pipeline) ShortStatusSummary() string {
+	if p.CiDefs_Pipeline == nil {
+		return ""
+	}
+	counts := p.Counts()
+	total := len(p.CiDefs_Pipeline.Workflows)
+	successes := counts["success"]
+	return fmt.Sprintf("%d/%d", successes, total)
+}
+
+func (p Pipeline) LongStatusSummary() string {
+	if p.CiDefs_Pipeline == nil {
+		return ""
+	}
+	counts := p.Counts()
+	total := len(p.CiDefs_Pipeline.Workflows)
+	var parts []string
+	states := []string{"success", "failed", "timeout", "cancelled", "running", "pending"}
+	for _, state := range states {
+		if c, ok := counts[state]; ok {
+			parts = append(parts, fmt.Sprintf("%d/%d %s", c, total, state))
+		}
+	}
+	return strings.Join(parts, ", ")
+}
+
+func (p Pipeline) TimeTaken() time.Duration {
+	if p.CiDefs_Pipeline == nil {
+		return 0
+	}
+	var s time.Duration
+	for _, w := range p.CiDefs_Pipeline.Workflows {
+		s += WorkflowStatus{CiDefs_Workflow: w}.TimeTaken()
+	}
+	return s
+}
+
+func (p Pipeline) Created() time.Time {
+	if p.CiDefs_Pipeline == nil || p.CreatedAt == nil || *p.CreatedAt == "" {
+		return time.Time{}
+	}
+	t, err := time.Parse(time.RFC3339, *p.CreatedAt)
+	if err != nil {
+		return time.Time{}
+	}
+	return t
+}
+
+func (p Pipeline) Trigger() Trigger {
+	if p.CiDefs_Pipeline == nil {
+		return Trigger{nil}
+	}
+	return Trigger{p.CiDefs_Pipeline.Trigger}
+}
+
+func (p Pipeline) IsResponding() bool {
+	return p.CiDefs_Pipeline != nil && len(p.CiDefs_Pipeline.Workflows) > 0
+}
+
+func (p Pipeline) Sha() string {
+	if p.CiDefs_Pipeline == nil {
+		return ""
+	}
+	return p.CiDefs_Pipeline.Commit
+}
+
+func (p Pipeline) Workflows() []string {
+	var ws []string
+	if p.CiDefs_Pipeline != nil {
+		for _, w := range p.CiDefs_Pipeline.Workflows {
+			ws = append(ws, w.Name)
+		}
+	}
+	return ws
+}