From 68d5ba2eacd48f4b94a27914402845c2d7502689 Mon Sep 17 00:00:00 2001 From: oppiliappan Date: Tue, 12 May 2026 10:25:40 +0100 Subject: [PATCH] appview/pipelines: switch all queries to use repo-did Signed-off-by: oppiliappan --- appview/pipelines/pipelines.go | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/appview/pipelines/pipelines.go b/appview/pipelines/pipelines.go index e57d301e..202ead11 100644 --- a/appview/pipelines/pipelines.go +++ b/appview/pipelines/pipelines.go @@ -150,9 +150,7 @@ func (p *Pipelines) Workflow(w http.ResponseWriter, r *http.Request) { ps, err := db.GetPipelineStatuses( p.db, 1, - orm.FilterEq("p.repo_owner", f.Did), - orm.FilterEq("p.repo_name", f.Rkey), - orm.FilterEq("p.knot", f.Knot), + orm.FilterEq("p.repo_did", f.RepoDid), orm.FilterEq("p.id", pipelineId), ) if err != nil { @@ -217,9 +215,7 @@ func (p *Pipelines) Logs(w http.ResponseWriter, r *http.Request) { ps, err := db.GetPipelineStatuses( p.db, 1, - orm.FilterEq("p.repo_owner", f.Did), - orm.FilterEq("p.repo_name", f.Rkey), - orm.FilterEq("p.knot", f.Knot), + orm.FilterEq("p.repo_did", f.RepoDid), orm.FilterEq("p.id", pipelineId), ) if err != nil || len(ps) != 1 { @@ -366,9 +362,7 @@ func (p *Pipelines) Cancel(w http.ResponseWriter, r *http.Request) { ps, err := db.GetPipelineStatuses( p.db, 1, - orm.FilterEq("p.repo_owner", f.Did), - orm.FilterEq("p.repo_name", f.Rkey), - orm.FilterEq("p.knot", f.Knot), + orm.FilterEq("p.repo_did", f.RepoDid), orm.FilterEq("p.id", pipelineId), ) if err != nil { -- 2.51.2