Method Run

pkg/devspace/pipeline/job.go:62–94

(ctx devspacecontext.Context, args []string, environ expand.Environ)

}

func (j *Job) Run(ctx devspacecontext.Context, args []string, environ expand.Environ) error {
	if ctx.IsDone() {
		return ctx.Context().Err()
	}

	j.m.Lock()
	ctx = ctx.WithContext(j.t.Context(ctx.Context()))
	t := j.t
	j.m.Unlock()

	t.Go(func() error {
		// start the actual job
		done := t.NotifyGo(func() error {
			return j.execute(ctx, args, t, environ)
		})

		// wait until job is dying
		select {
		case <-ctx.Context().Done():
			return nil
		case <-done:
		}

		// check if errored
		if !t.Alive() {
			return t.Err()
		}

		return nil
	})

	return t.Wait()
}

func (j *Job) execute(ctx devspacecontext.Context, args []string, parent *tomb.Tomb, environ expand.Environ) error {
	ctx = ctx.WithLogger(ctx.Log())