func (a *apiServer) makePipelineInfoCommit(pachClient *client.APIClient, pipelineInfo *pps.PipelineInfo) (result *pfs.Commit, retErr error) {
	pipelineName := pipelineInfo.Pipeline.Name
	var commit *pfs.Commit
	if err := a.sudo(pachClient, func(superUserClient *client.APIClient) error {
		data, err := pipelineInfo.Marshal()
		if err != nil {
			return fmt.Errorf("could not marshal PipelineInfo: %v", err)
		}
		if _, err = superUserClient.PutFileOverwrite(ppsconsts.SpecRepo, pipelineName, ppsconsts.SpecFile, bytes.NewReader(data), 0); err != nil {
			return err
		}
		branchInfo, err := superUserClient.InspectBranch(ppsconsts.SpecRepo, pipelineName)
		if err != nil {
			return err
		}
		commit = branchInfo.Head
		return nil
	}); err != nil {
		return nil, err
	}
	return commit, nil
}
func (a *apiServer) makePipelineInfoCommit(pachClient *client.APIClient, pipelineInfo *pps.PipelineInfo) (result *pfs.Commit, retErr error) {
	pipelineName := pipelineInfo.Pipeline.Name
	var commit *pfs.Commit
	if err := a.sudo(pachClient, func(superUserClient *client.APIClient) error {
		data, err := pipelineInfo.Marshal()
		if err != nil {
			return fmt.Errorf("could not marshal PipelineInfo: %v", err)
		}
		if _, err = superUserClient.PutFileOverwrite(ppsconsts.SpecRepo, pipelineName, ppsconsts.SpecFile, bytes.NewReader(data), 0); err != nil {
			return err
		}
		branchInfo, err := superUserClient.InspectBranch(ppsconsts.SpecRepo, pipelineName)
		if err != nil {
			return err
		}
		commit = branchInfo.Head
		return nil
	}); err != nil {
		return nil, err
	}
	return commit, nil
}
func ( a * apiServer ) makePipelineInfoCommit ( pachClient * client . APIClient , pipelineInfo * pps . PipelineInfo ) ( result * pfs . Commit , retErr error ) { pipelineName := pipelineInfo . Pipeline . Name var commit * pfs . Commit if err := a . sudo ( pachClient , func ( superUserClient * client . APIClient ) error { data , err := pipelineInfo . Marshal ( ) if err != nil { return fmt . Errorf ( " " , err ) } if _ , err = superUserClient . PutFileOverwrite ( ppsconsts . SpecRepo , pipelineName , ppsconsts . SpecFile , bytes . NewReader ( data ) , 0 ) ; err != nil { return err } branchInfo , err := superUserClient . InspectBranch ( ppsconsts . SpecRepo , pipelineName ) if err != nil { return err } commit = branchInfo . Head return nil } ) ; err != nil { return nil , err } return commit , nil }
// makePipelineInfoCommit is a helper for CreatePipeline that creates a commit
// with 'pipelineInfo' in SpecRepo (in PFS). It's called in both the case where
// a user is updating a pipeline and the case where a user is creating a new
// pipeline.
makePipelineInfoCommit is a helper for CreatePipeline that creates a commit with pipelineInfo in SpecRepo ( in PFS ) . It s called in both the case where a user is updating a pipeline and the case where a user is creating a new pipeline .