From 80b9d712b590ad5f6aeb966b02ec3556a9ecd3f2 Mon Sep 17 00:00:00 2001 From: Asif Saif Uddin Date: Mon, 11 Mar 2019 17:47:56 +0600 Subject: [PATCH] added initial redis cluster tranport initialization --- kombu/transport/__init__.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kombu/transport/__init__.py b/kombu/transport/__init__.py index 64dd35c66..52ba6747e 100644 --- a/kombu/transport/__init__.py +++ b/kombu/transport/__init__.py @@ -43,7 +43,8 @@ def supports_librabbitmq() -> bool | None: 'etcd': 'kombu.transport.etcd:Transport', 'azurestoragequeues': 'kombu.transport.azurestoragequeues:Transport', 'azureservicebus': 'kombu.transport.azureservicebus:Transport', - 'pyro': 'kombu.transport.pyro:Transport' + 'pyro': 'kombu.transport.pyro:Transport', + 'redis-cluster': 'kombu.transport.redis_cluster:Transport', } _transport_cache = {}