Skip to content

Commit

Permalink
fix fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
lance6716 committed Nov 16, 2021
1 parent cff0bab commit 43acd7a
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions dm/dm/master/scheduler/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -1758,9 +1758,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()
Expand Down

0 comments on commit 43acd7a

Please sign in to comment.