fix(hatchery): break on already registering (#4248)

Signed-off-by: Yvonnick Esnault <yvonnick.esnault@corp.ovh.com>
ovh · May 3, 2019 · b67b1e9 · b67b1e9
1 parent e515b80
commit b67b1e9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sdk/hatchery/register.go b/sdk/hatchery/register.go
@@ -29,6 +29,7 @@ func workerRegister(ctx context.Context, h Interface, startWorkerChan chan<- wor
 	}
 
 	atomic.StoreInt64(&nbRegisteringWorkerModels, int64(len(currentRegistering)))
+loopModels:
 	for k := range models {
 		if models[k].Type != h.ModelType() {
 			continue
@@ -57,7 +58,7 @@ func workerRegister(ctx context.Context, h Interface, startWorkerChan chan<- wor
 		for _, w := range currentRegistering {
 			if strings.Contains(w.Name, models[k].Name) {
 				log.Info("hatchery> workerRegister> %s is already registering (%s)", models[k].Name, w.Name)
-				continue
+				continue loopModels
 			}
 		}