in cli_tools/common/utils/daisyutils/daisy_utils.go [432:461]
func ParseWorkflow(path string, varMap map[string]string, project, zone, gcsPath, oauth, dTimeout, cEndpoint string, disableGCSLogs, disableCloudLogs, disableStdoutLogs bool) (*daisy.Workflow, error) {
w, err := daisy.NewFromFile(path)
if err != nil {
return nil, err
}
Loop:
for k, v := range varMap {
for wv := range w.Vars {
if k == wv {
w.AddVar(k, v)
continue Loop
}
}
return nil, daisy.Errf("unknown workflow Var %q passed to Workflow %q", k, w.Name)
}
EnvironmentSettings{
Project: project,
Zone: zone,
GCSPath: gcsPath,
OAuth: oauth,
Timeout: dTimeout,
ComputeEndpoint: cEndpoint,
DisableGCSLogs: disableGCSLogs,
DisableCloudLogs: disableCloudLogs,
DisableStdoutLogs: disableStdoutLogs,
}.ApplyToWorkflow(w)
return w, nil
}