Fix incompatibility with redis in disconnect() (#1589)

* Accept *args in disconnect()

* Add test for redis connection timeout error

kombu/transport/redis.py

@@ -1185,8 +1185,8 @@ def _connparams(self, asynchronous=False):
 
         if asynchronous:
             class Connection(connection_cls):
-                def disconnect(self):
-                    super().disconnect()
+                def disconnect(self, *args):
+                    super().disconnect(*args)
                     channel._on_connection_disconnect(self)
             connection_cls = Connection
 

t/integration/test_redis.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 import os
+import socket
 from time import sleep
 
 import pytest
@@ -134,3 +135,18 @@ def callback(body, message):
 @pytest.mark.flaky(reruns=5, reruns_delay=2)
 class test_RedisMessage(BaseMessage):
     pass
+
+
+@pytest.mark.env('redis')
+def test_RedisConnectTimeout(monkeypatch):
+    # simulate a connection timeout for a new connection
+    def connect_timeout(self):
+        raise socket.timeout
+    monkeypatch.setattr(
+        redis.connection.Connection, "_connect", connect_timeout)
+
+    # ensure the timeout raises a TimeoutError
+    with pytest.raises(redis.exceptions.TimeoutError):
+        # note the host/port here is irrelevant because
+        # connect will raise a socket.timeout
+        kombu.Connection('redis://localhost:12345').connect()