in testworkflow.go [326:353]
func (t *TestWorkflow) appendCreateDisksStep(diskParams *compute.Disk) (*daisy.Step, error) {
if diskParams == nil || diskParams.Name == "" {
return nil, fmt.Errorf("failed to create disk with empty parameters")
}
bootdisk := &daisy.Disk{}
bootdisk.Name = diskParams.Name
bootdisk.SourceImage = t.ImageURL
bootdisk.Type = diskParams.Type
bootdisk.Zone = diskParams.Zone
bootdisk.SizeGb = strconv.FormatInt(diskParams.SizeGb, 10)
createDisks := &daisy.CreateDisks{bootdisk}
createDisksStep, ok := t.wf.Steps[createDisksStepName]
if ok {
// append to existing step.
*createDisksStep.CreateDisks = append(*createDisksStep.CreateDisks, bootdisk)
} else {
var err error
createDisksStep, err = t.wf.NewStep(createDisksStepName)
if err != nil {
return nil, err
}
createDisksStep.CreateDisks = createDisks
}
return createDisksStep, nil
}