diff --git a/dm/dm/master/scheduler/scheduler.go b/dm/dm/master/scheduler/scheduler.go
index c04ccf836b3..7b7dcb2557a 100644
--- a/dm/dm/master/scheduler/scheduler.go
+++ b/dm/dm/master/scheduler/scheduler.go
@@ -1785,9 +1785,9 @@ func (s *Scheduler) handleWorkerOnline(ev ha.WorkerEvent, toLock bool) error {
 		// of course nothing, so we find the relay source from a better place
 		for source, workerM := range s.relayWorkers {
 			if _, ok2 := workerM[w.BaseInfo().Name]; ok2 {
-                lastRelaySource = source
-                break
-            }
+				lastRelaySource = source
+				break
+			}
 		}
 	}
 	w.ToFree()