From 32e768c766b909694de32fad69ef7b1d5e767772 Mon Sep 17 00:00:00 2001 From: shubhendu Date: Tue, 25 Apr 2017 16:46:41 +0530 Subject: [PATCH] Set access_policy for messaging's dispatcher oslo.messaging allow dispatcher to restrict endpoint methods since 5.11.0 in d3a8f280ebd6fd12865fd20c4d772774e39aefa2, set with DefaultRPCAccessPolicy to fix FutureWarning like: FutureWarning: The access_policy argument is changing its default value to in version '?', please update the code to explicitly set None as the value: access_policy defaults to LegacyRPCAccessPolicy which exposes private methods. Explicitly set access_policy to DefaultRPCAccessPolicy or ExplicitRPCAccessPolicy. Change-Id: I4ef639d3f93bc56884e92ce17ced091dcebb4170 --- cloudkitty/messaging.py | 5 ++++- requirements.txt | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/cloudkitty/messaging.py b/cloudkitty/messaging.py index 3ffa28ef..808417e8 100644 --- a/cloudkitty/messaging.py +++ b/cloudkitty/messaging.py @@ -15,6 +15,7 @@ from oslo_config import cfg import oslo_messaging +from oslo_messaging.rpc import dispatcher DEFAULT_URL = "__default__" RPC_TARGET = None @@ -60,11 +61,13 @@ def get_client(version_cap=None): def get_server(target=None, endpoints=None): + access_policy = dispatcher.DefaultRPCAccessPolicy transport = get_transport() if not target: target = get_target() return oslo_messaging.get_rpc_server(transport, target, - endpoints, executor='eventlet') + endpoints, executor='eventlet', + access_policy=access_policy) def cleanup(): diff --git a/requirements.txt b/requirements.txt index e9c1af86..c91fbd2b 100644 --- a/requirements.txt +++ b/requirements.txt @@ -19,7 +19,7 @@ oslo.concurrency>=3.5.0 # Apache-2.0 oslo.db>=4.1.0 # Apache-2.0 oslo.i18n>=2.1.0 # Apache-2.0 oslo.log>=1.14.0 # Apache-2.0 -oslo.messaging>=5.2.0 # Apache-2.0 +oslo.messaging>=5.11.0 # Apache-2.0 oslo.middleware>=3.0.0 # Apache-2.0 oslo.policy>=0.5.0 # Apache-2.0 oslo.utils>=3.5.0 # Apache-2.0