Handle generating pipeline failure

Author: ZhuGongpu

internal/cmdexport/cmdexport.go

@@ -87,7 +87,11 @@ type ExportRunner struct {
 
 // runE generates the pipeline and writes it into a file or stdout.
 func (r *ExportRunner) runE(c *cobra.Command, args []string) error {
-	pipeline := r.Pipeline.Init(r.PipelineConfig).Generate()
+	pipeline, e := r.Pipeline.Init(r.PipelineConfig).Generate()
+
+	if e != nil {
+		return e
+	}
 
 	if r.OutputFilePath != "" {
 		fo, err := os.Create(r.OutputFilePath)

internal/cmdexport/orchestrators/cloudbuild.go

@@ -54,8 +54,6 @@ func (p *CloudBuild) Init(config *types.PipelineConfig) Pipeline {
 	return p
 }
 
-func (p *CloudBuild) Generate() []byte {
-	data, _ := yaml.Marshal(p)
-
-	return data
+func (p *CloudBuild) Generate() (out []byte, err error) {
+	return yaml.Marshal(p)
 }

internal/cmdexport/orchestrators/githubactions.go

@@ -82,8 +82,6 @@ func (p *GitHubActions) Init(config *types.PipelineConfig) Pipeline {
 	return p
 }
 
-func (p *GitHubActions) Generate() []byte {
-	data, _ := yaml.Marshal(p)
-
-	return data
+func (p *GitHubActions) Generate() (out []byte, err error) {
+	return yaml.Marshal(p)
 }

internal/cmdexport/orchestrators/pipeline.go

@@ -22,5 +22,5 @@ const KptImage = "gongpu/kpt:latest"
 // Pipeline is an abstraction of different workflow orchestrators.
 type Pipeline interface {
 	Init(config *types.PipelineConfig) Pipeline
-	Generate() []byte
+	Generate() (out []byte, err error)
 }

internal/cmdexport/orchestrators/pipeline_test.go

@@ -47,7 +47,7 @@ func TestPipeline(t *testing.T) {
 			testCase := testCases[i]
 
 			t.Run(testCase.description, func(t *testing.T) {
-				pipeline := pipeline.Init(testCase.config).Generate()
+				pipeline, _ := pipeline.Init(testCase.config).Generate()
 
 				actual := string(pipeline)
 				expected := strings.TrimLeft(testCase.expected, "\n")