update, test=develop (#29139)

216e0856 · lilong12 · GitHub · 5fe44571 · 216e0856
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

python/paddle/distributed/parallel.py python/paddle/distributed/parallel.py +1 -1

未找到文件。
--- a/python/paddle/distributed/parallel.py
+++ b/python/paddle/distributed/parallel.py
@@ -49,7 +49,7 @@ def _start_kv_server(port, http_server_d):
    http_server = KVServer(int(port))
    http_server.start()
    wait_seconds = 5
-    while http_server_d.get("running", False):
+    while http_server_d.get("running", False) or not http_server.should_stop():
        time.sleep(wait_seconds)
    http_server.stop()