From f69b8da7024ed4f105ecb428989a46c173ce3ac0 Mon Sep 17 00:00:00 2001 From: Takashi Kajinami Date: Tue, 29 Oct 2024 23:59:27 +0900 Subject: [PATCH] Select appropriate transport implementation according to API version instead of always using the one for v1 API. Also, get_transport_url may never return negative value so 'or' check is never used. Change-Id: Iff92d704ddd52a0bdcb62e60fa2f86c615f9f36f --- zaqarclient/queues/v1/client.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/zaqarclient/queues/v1/client.py b/zaqarclient/queues/v1/client.py index 727e2d0f..fea50582 100644 --- a/zaqarclient/queues/v1/client.py +++ b/zaqarclient/queues/v1/client.py @@ -63,9 +63,9 @@ class Client(object): :type request: :class:`zaqarclient.transport.request.Request` """ - trans = transport.get_transport_for(request, - options=self.conf) - return (trans or self.transport) + return transport.get_transport_for(request, + version=self.api_version, + options=self.conf) def _request_and_transport(self): req = request.prepare_request(self.auth_opts, @@ -84,7 +84,7 @@ class Client(object): :rtype: :class:`zaqarclient.transport.base.Transport` """ return transport.get_transport_for(self.api_url, - self.api_version) + version=self.api_version) def queue(self, ref, **kwargs): """Returns a queue instance