Correctly close

sendbird · May 8, 2023 · b3a1eb6 · b3a1eb6
1 parent 1d3218a
commit b3a1eb6
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/kombu/transport/redis_cluster.py b/kombu/transport/redis_cluster.py
@@ -202,6 +202,12 @@ def conn_or_acquire(self, client=None):
         else:
             yield self.client
 
+    def close(self):
+        for _, _, conn, _ in self.connection.cycle._chan_to_sock:
+            conn.client.close()
+
+        return super().close()
+
     def _create_client(self, asynchronous=False):
         conninfo = self.connection.client