Function applyFlags

pkg/devspace/pipeline/pipeline.go:425–467

(ctx devspacecontext.Context, pipeline *latest.Pipeline, setFlags []string)

}

func applyFlags(ctx devspacecontext.Context, pipeline *latest.Pipeline, setFlags []string) (devspacecontext.Context, error) {
	defaultFlags := map[string]string{}
	for _, flag := range pipeline.Flags {
		val, err := GetDefaultValue(flag)
		if err != nil {
			return nil, err
		}

		switch flag.Type {
		case latest.PipelineFlagTypeStringArray:
			defaultFlags[flag.Name] = fmt.Sprintf("%v", strings.Join(val.([]string), " "))
		default:
			defaultFlags[flag.Name] = fmt.Sprintf("%v", val)
		}
	}

	newFlags := map[string]string{}
	for _, v := range setFlags {
		splitted := strings.Split(v, "=")
		if len(splitted) <= 1 {
			return nil, fmt.Errorf("error parsing flag %s: expected format flag=value", v)
		}

		flagName := splitted[0]
		flagVal := strings.Join(splitted[1:], "=")
		flagVals := strings.Join(strings.Split(flagVal, ","), " ")

		if newFlags[flagName] != "" {
			newFlags[flagName] = strings.Join([]string{newFlags[flagName], flagVals}, " ")
		} else {
			newFlags[flagName] = flagVals
		}

	}

	for name, value := range defaultFlags {
		if _, ok := newFlags[name]; !ok {
			newFlags[name] = value
		}
	}

	return ctx.WithContext(values.WithFlagsMap(ctx.Context(), newFlags)), nil
}

func (p *pipeline) createJob(configPipeline *latest.Pipeline, id string) (job *Job, err error) {
	p.m.Lock()