未验证 提交 a998c077 编写于 作者: K kuizhiqing 提交者: GitHub

fix http gloo bug (#39017)

上级 2052f1e3
......@@ -224,10 +224,6 @@ class Gloo(object):
self._worker_comm = gloo
# TODO (sandyhouse): initialize gloo for server and all
if start_http_server:
http_server_d["running"] = False
http_server.join()
def _get_rank_nodes(self, role):
nodes = 0
rank = -1
......
......@@ -734,11 +734,6 @@ class GeneralRoleMaker(RoleMakerBase):
self._rank = all_list.index(self._cur_endpoint)
self._size = len(all_list)
self._worker_endpoints = worker_endpoints
if self._http_server is not None:
# set running status to False
self._http_server_d["running"] = False
# wait until child process exits
self._http_server.join()
self._role_is_generated = True
def all_gather(self, input):
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册