src/client/pps.go
func (c APIClient) StartPipeline(name string) error {
	_, err := c.PpsAPIClient.StartPipeline(
		c.Ctx(),
		&pps.StartPipelineRequest{
			Pipeline: NewPipeline(name),
		},
	)
	return grpcutil.ScrubGRPC(err)
}
func (c APIClient) StartPipeline(name string) error {
	_, err := c.PpsAPIClient.StartPipeline(
		c.Ctx(),
		&pps.StartPipelineRequest{
			Pipeline: NewPipeline(name),
		},
	)
	return grpcutil.ScrubGRPC(err)
}
func ( c APIClient ) StartPipeline ( name string ) error { _ , err := c . PpsAPIClient . StartPipeline ( c . Ctx ( ) , & pps . StartPipelineRequest { Pipeline : NewPipeline ( name ) , } , ) return grpcutil . ScrubGRPC ( err ) }
// StartPipeline restarts a stopped pipeline.
StartPipeline restarts a stopped pipeline .