diff --git a/cyborg/common/rpc.py b/cyborg/common/rpc.py index fde53ee8..28d12d6f 100644 --- a/cyborg/common/rpc.py +++ b/cyborg/common/rpc.py @@ -96,10 +96,9 @@ class RequestContextSerializer(messaging.Serializer): def get_client(target, version_cap=None, serializer=None): assert TRANSPORT is not None serializer = RequestContextSerializer(serializer) - return messaging.RPCClient(TRANSPORT, - target, - version_cap=version_cap, - serializer=serializer) + return messaging.get_rpc_client( + TRANSPORT, target, version_cap=version_cap, + serializer=serializer) def get_server(target, endpoints, serializer=None): diff --git a/requirements.txt b/requirements.txt index 3989b822..98dbc735 100644 --- a/requirements.txt +++ b/requirements.txt @@ -10,7 +10,7 @@ oslo.i18n>=1.5.0 # Apache-2.0 oslo.config>=1.1.0,!=4.3.0,!=4.4.0 # Apache-2.0 oslo.log>=5.0.0 # Apache-2.0 oslo.context>=2.9.0 # Apache-2.0 -oslo.messaging>=10.3.0 # Apache-2.0 +oslo.messaging>=14.1.0 # Apache-2.0 oslo.concurrency>=3.26.0 # Apache-2.0 oslo.service>=1.0.0,!=1.28.1 # Apache-2.0 oslo.db>=10.0.0 # Apache-2.0