diff --git a/cluster/watchdog.go b/cluster/watchdog.go
index aa43227a6c..c1dd475ed9 100644
--- a/cluster/watchdog.go
+++ b/cluster/watchdog.go
@@ -20,7 +20,7 @@ func (w *Watchdog) Handle(e *Event) error {
 	}
 
 	switch e.Status {
-	case "engine_reconnect":
+	case "engine_connect", "engine_reconnect":
 		go w.removeDuplicateContainers(e.Engine)
 	case "engine_disconnect":
 		go w.rescheduleContainers(e.Engine)