Unverified Commit 7afd1d0d authored by Chao Ma's avatar Chao Ma Committed by GitHub
Browse files

[KVStore] Fix a small bug (#1686)

* update

* update

* update

* update

* update
parent 86c243b4
...@@ -829,7 +829,7 @@ class KVClient(object): ...@@ -829,7 +829,7 @@ class KVClient(object):
for server_id in range(self._server_count): for server_id in range(self._server_count):
rpc.send_request(server_id, request) rpc.send_request(server_id, request)
# recv response from all the server nodes # recv response from all the server nodes
for _ in range(self._server_namebook): for _ in range(self._server_count):
response = rpc.recv_response() response = rpc.recv_response()
assert response.msg == REGISTER_PULL_MSG assert response.msg == REGISTER_PULL_MSG
self._pull_handlers[name] = func self._pull_handlers[name] = func
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment