The master does not add the worker host if it is in the next group (#2504)

workingloong · web-flow · commit e949313159f1 · 2021-02-20T13:29:01.000+08:00
diff --git a/elasticdl/python/master/rendezvous_server.py b/elasticdl/python/master/rendezvous_server.py
@@ -145,7 +145,8 @@ def add_worker(self, worker_host):
                     self._next_rendezvous_hosts = copy.deepcopy(
                         self._cur_rendezvous_hosts
                     )
-                self._next_rendezvous_hosts.append(worker_host)
+                if worker_host not in self._next_rendezvous_hosts:
+                    self._next_rendezvous_hosts.append(worker_host)
 
     def remove_worker(self, worker_host):
         with self._lock:

Original file line number	Diff line number	Diff line change
`@@ -145,7 +145,8 @@ def add_worker(self, worker_host):`
`145`	`145`	`self._next_rendezvous_hosts = copy.deepcopy(`
`146`	`146`	`self._cur_rendezvous_hosts`
`147`	`147`	`)`
`148`		`- self._next_rendezvous_hosts.append(worker_host)`
	`148`	`+ if worker_host not in self._next_rendezvous_hosts:`
	`149`	`+ self._next_rendezvous_hosts.append(worker_host)`
`149`	`150`
`150`	`151`	`def remove_worker(self, worker_host):`
`151`	`152`	`with self._lock:`