Method ListTaskRuns

backend/api/v1/rollout_service.go:324–371

ListTaskRuns lists rollout task runs.

(ctx context.Context, req *connect.Request[v1pb.ListTaskRunsRequest])

// ListTaskRuns lists rollout task runs.
func (s *RolloutService) ListTaskRuns(ctx context.Context, req *connect.Request[v1pb.ListTaskRunsRequest]) (*connect.Response[v1pb.ListTaskRunsResponse], error) {
	request := req.Msg
	projectID, planID, maybeStageID, maybeTaskID, err := common.GetProjectIDPlanIDMaybeStageIDMaybeTaskID(request.Parent)
	if err != nil {
		return nil, connect.NewError(connect.CodeInvalidArgument, err)
	}

	project, err := s.store.GetProject(ctx, &store.FindProjectMessage{
		Workspace:  common.GetWorkspaceIDFromContext(ctx),
		ResourceID: &projectID,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to find project"))
	}
	if project == nil {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("project %v not found", projectID))
	}

	plan, err := s.store.GetPlan(ctx, &store.FindPlanMessage{
		Workspace: common.GetWorkspaceIDFromContext(ctx),
		ProjectID: projectID,
		UID:       &planID,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to get rollout"))
	}
	if plan == nil {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("rollout %d not found in project %s", planID, projectID))
	}
	taskRuns, err := s.store.ListTaskRuns(ctx, &store.FindTaskRunMessage{
		Workspace:   common.GetWorkspaceIDFromContext(ctx),
		ProjectID:   projectID,
		PlanUID:     &planID,
		Environment: maybeStageID,
		TaskUID:     maybeTaskID,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to list task runs"))
	}

	taskRunsV1, err := convertToTaskRuns(ctx, s.store, taskRuns)
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to convert to task runs"))
	}
	return connect.NewResponse(&v1pb.ListTaskRunsResponse{
		TaskRuns: taskRunsV1,
	}), nil
}

// CreateRolloutAndPendingTasks creates rollout tasks and pending task runs.
func CreateRolloutAndPendingTasks(