fix flask_nameko bug 5

This commit is contained in:
BryantHe 2023-06-01 05:04:51 +08:00
parent bc3619a83b
commit 77bc4a0706
1 changed files with 1 additions and 2 deletions

View File

@ -36,8 +36,7 @@ class PooledClusterRpcProxy(object):
def _get_nameko_connection(self): def _get_nameko_connection(self):
proxy = ClusterRpcClient( proxy = ClusterRpcClient(
self._config, uri=self._config.get('uri')
timeout=self._config.get('RPC_TIMEOUT', None)
) )
return proxy.start() return proxy.start()