Apply errback and callback when retry occurs.

celery · Sep 30, 2024 · 14a7b22 · 14a7b22
1 parent 74779a8
commit 14a7b22
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kombu/connection.py b/kombu/connection.py
@@ -903,6 +903,10 @@ def _extract_failover_opts(self):
             if 'connect_retries_timeout' in transport_opts:
                 conn_opts['timeout'] = \
                     transport_opts['connect_retries_timeout']
+            if 'errback' in transport_opts:
+                conn_opts['errback'] = transport_opts['errback']
+            if 'callback' in transport_opts:
+                conn_opts['callback'] = transport_opts['callback']
         return conn_opts
 
     @property