Method execute

pkg/devspace/pipeline/job.go:96–123

(ctx devspacecontext.Context, args []string, parent *tomb.Tomb, environ expand.Environ)

}

func (j *Job) execute(ctx devspacecontext.Context, args []string, parent *tomb.Tomb, environ expand.Environ) error {
	ctx = ctx.WithLogger(ctx.Log())
	stdoutReader, stdoutWriter := io.Pipe()
	defer stdoutWriter.Close()

	parent.Go(func() error {
		s := scanner.NewScanner(stdoutReader)
		for s.Scan() {
			ctx.Log().Info(s.Text())
		}
		return nil
	})

	stderrReader, stderrWriter := io.Pipe()
	defer stderrWriter.Close()

	parent.Go(func() error {
		s := scanner.NewScanner(stderrReader)
		for s.Scan() {
			ctx.Log().Warn(s.Text())
		}
		return nil
	})

	handler := pipelinehandler.NewPipelineExecHandler(ctx, stdoutWriter, stderrWriter, j.Pipeline)
	_, err := engine.ExecutePipelineShellCommand(ctx.Context(), j.Config.Run, args, ctx.WorkingDir(), j.Config.ContinueOnError, stdoutWriter, stderrWriter, os.Stdin, environ, handler)
	return err
}