Propagate catalog query errors in GetPeerflow

pfcoperez · pfcoperez · commit c680aec510e3 · 2026-04-07T18:21:05.000+02:00
diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
@@ -653,7 +653,7 @@ func GetPeerflow(ctx context.Context, catalog *pgx.Conn, tc client.Client, flowN
 	if err := catalog.QueryRow(
 		ctx, "select workflow_id from flows where name = $1", flowName,
 	).Scan(&workflowID); err != nil {
-		return WorkflowRun{}, nil
+		return WorkflowRun{}, fmt.Errorf("failed to get workflow_id for flow %s: %w", flowName, err)
 	}
 	return WorkflowRun{WorkflowRun: tc.GetWorkflow(ctx, workflowID, ""), c: tc}, nil
 }

Original file line number	Diff line number	Diff line change
`@@ -653,7 +653,7 @@ func GetPeerflow(ctx context.Context, catalog *pgx.Conn, tc client.Client, flowN`
`653`	`653`	`if err := catalog.QueryRow(`
`654`	`654`	`ctx, "select workflow_id from flows where name = $1", flowName,`
`655`	`655`	`).Scan(&workflowID); err != nil {`
`656`		`- return WorkflowRun{}, nil`
	`656`	`+ return WorkflowRun{}, fmt.Errorf("failed to get workflow_id for flow %s: %w", flowName, err)`
`657`	`657`	`}`
`658`	`658`	`return WorkflowRun{WorkflowRun: tc.GetWorkflow(ctx, workflowID, ""), c: tc}, nil`
`659`	`659`	`}`