diff --git a/zaqarclient/queues/v1/queues.py b/zaqarclient/queues/v1/queues.py index 63f0c933..6a81ba26 100644 --- a/zaqarclient/queues/v1/queues.py +++ b/zaqarclient/queues/v1/queues.py @@ -69,7 +69,7 @@ class Queue(object): right after it was called. """ req, trans = self.client._request_and_transport() - if force_create or req.api.is_supported('queue_set_metadata'): + if force_create or float(self.client.api_version) < 1.1: core.queue_create(trans, req, self._name) def metadata(self, new_meta=None, force_reload=False): @@ -93,7 +93,7 @@ class Queue(object): # NOTE(jeffrey4l): Ensure that metadata is cleared when the new_meta # is a empty dict. if new_meta is not None: - if req.api.is_supported('queue_set_metadata'): + if float(self.client.api_version) < 1.1: core.queue_set_metadata(trans, req, self._name, new_meta) else: core.queue_create(trans, req, self._name, metadata=new_meta)