return
}
+ defer func() { <-lr.concurrencyLimit }()
+
waitGroup.Add(1)
+ defer waitGroup.Done()
cmd := exec.Command(*crunchRunCommand, uuid)
cmd.Stdin = nil
delete(runningCmds, uuid)
runningCmdsMutex.Unlock()
}
- waitGroup.Done()
}
// If the container is not finalized, then change it to "Cancelled".