diff --git a/py_eureka_client/eureka_client.py b/py_eureka_client/eureka_client.py index b12773b..bb0fe75 100644 --- a/py_eureka_client/eureka_client.py +++ b/py_eureka_client/eureka_client.py @@ -396,7 +396,7 @@ def __init__(self, assert ha_strategy in (HA_STRATEGY_RANDOM, HA_STRATEGY_STICK, HA_STRATEGY_OTHER) if should_discover else True, f"do not support strategy {ha_strategy}" - self.__net_lock = RLock() + self.__net_lock = asyncio.Lock() self.__eureka_server_conf = EurekaServerConf( eureka_server=eureka_server, eureka_domain=eureka_domain, @@ -634,7 +634,7 @@ async def __try_all_eureka_servers(self, fun): await self.__try_eureka_server_regardless_zones(fun) async def __try_eureka_servers_in_list(self, fun, eureka_servers=[], zone=_DEFAUTL_ZONE): - with self.__net_lock: + async with self.__net_lock: ok = False _zone = zone if zone else _DEFAUTL_ZONE for url in eureka_servers: