Adding a default ephemeral disk if it's not added by default

This commit is contained in:
Diptanu Choudhury
2016-11-02 15:07:22 -07:00
parent 6a0999c11f
commit bc876f14a8

View File

@@ -1653,6 +1653,11 @@ func (tg *TaskGroup) Canonicalize(job *Job) {
tg.RestartPolicy = NewRestartPolicy(job.Type)
}
// Set a default ephemeral disk object if the user has not requested for one
if tg.EphemeralDisk == nil {
tg.EphemeralDisk = DefaultEphemeralDisk()
}
for _, task := range tg.Tasks {
task.Canonicalize(job, tg)
}