Function MakePipelinePlanTask

backend/helpers/pluginhelper/api/pipeline_plan.go:60–100

(
	pluginName string,
	subtaskMetas []plugin.SubTaskMeta,
	entities []string,
	options interface{},
)

}

func MakePipelinePlanTask(
	pluginName string,
	subtaskMetas []plugin.SubTaskMeta,
	entities []string,
	options interface{},
) (*models.PipelineTask, errors.Error) {
	// get subtasks enabled by default
	cfg := config.GetConfig()
	enableSubtasksByDefault := cfg.GetString("ENABLE_SUBTASKS_BY_DEFAULT")
	enableSubtasksList := strings.Split(enableSubtasksByDefault, ",")
	for s := range subtaskMetas {
		compareName := pluginName + ":" + subtaskMetas[s].Name
		for _, enableSubtask := range enableSubtasksList {
			subtaskInfo := strings.Split(enableSubtask, ":")
			if len(subtaskInfo) > 2 {
				subtaskInfoName := subtaskInfo[0] + ":" + subtaskInfo[1]
				if subtaskInfoName == compareName {
					v, err := strconv.ParseBool(subtaskInfo[2])
					if err != nil {
						break
					}
					subtaskMetas[s].EnabledByDefault = v
				}
			}
		}
	}

	subtasks, err := MakePipelinePlanSubtasks(subtaskMetas, entities)
	if err != nil {
		return nil, err
	}
	op, err := encodeTaskOptions(options)
	if err != nil {
		return nil, err
	}
	return &models.PipelineTask{
		Plugin:   pluginName,
		Subtasks: subtasks,
		Options:  op,
	}, nil
}

func encodeTaskOptions(op interface{}) (map[string]interface{}, errors.Error) {
	var result map[string]interface{}