func()

in internal/task/run_config.go [58:82]


func (tr *taskRunner) buildScriptsConfigMapObject(
	ctx context.Context,
) (*k8scorev1.ConfigMap, error) {
	data := map[string]string{}
	for _, file := range tr.taskConfig.Files {
		sourceFileContent, err := tr.resolveSourceFileContent(ctx, file.Source)
		if err != nil {
			return nil, fmt.Errorf("resolve %q: %w", file.Source, err)
		}
		data[file.Dest] = sourceFileContent
	}

	rv := &k8scorev1.ConfigMap{
		ObjectMeta: k8smetav1.ObjectMeta{
			Name:      tr.scriptsConfigMapName(),
			Namespace: tr.objectNamespace(),
			Labels: map[string]string{
				labelKeyTaskName: tr.taskConfig.Name,
			},
		},
		Data: data,
	}

	return rv, nil
}