Apply errback and callback when retry occurs.

celery · Oct 3, 2024 · db4973a · db4973a
1 parent ea6a160
commit db4973a
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