Browse Source

Retry tasks now inherit expires from parent. Closes #980

Must not be ported to 3.0 branch (see issue).
Ask Solem 12 years ago
parent
commit
cb3d7bb0e0
1 changed files with 1 additions and 0 deletions
  1. 1 0
      celery/app/task.py

+ 1 - 0
celery/app/task.py

@@ -546,6 +546,7 @@ class Task(object):
         if delivery_info:
             options.setdefault('exchange', delivery_info.get('exchange'))
             options.setdefault('routing_key', delivery_info.get('routing_key'))
+        options.setdefault('expires', request.expires)
 
         if not eta and countdown is None:
             countdown = self.default_retry_delay