diff options
| author | davidbossanyi <davebossanyi@gmail.com> | 2022-08-20 18:20:52 +0100 |
|---|---|---|
| committer | Asif Saif Uddin <auvipy@gmail.com> | 2022-08-21 01:48:19 +0600 |
| commit | 0e57a7b3a0edde7bad7061e73f741296ce06c3c8 (patch) | |
| tree | da03f59005ccb8aafd1e7445afad16f1904a8203 | |
| parent | 83e21c838252accb446f0f54e0d852d81cbd7f9b (diff) | |
| download | kombu-0e57a7b3a0edde7bad7061e73f741296ce06c3c8.tar.gz | |
fix: save QueueProperties to _queue_name_cache instead of QueueClient
| -rw-r--r-- | kombu/transport/azurestoragequeues.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/azurestoragequeues.py b/kombu/transport/azurestoragequeues.py index b608feac..0e3837a8 100644 --- a/kombu/transport/azurestoragequeues.py +++ b/kombu/transport/azurestoragequeues.py @@ -103,7 +103,7 @@ class Channel(virtual.Channel): except ResourceExistsError: q = self._queue_service.get_queue_client(queue=queue) - self._queue_name_cache[queue] = q + self._queue_name_cache[queue] = q.get_queue_properties() return q def _delete(self, queue, *args, **kwargs): |