Quellcode durchsuchen

Pass additional options in Task.retry

Additional options like queue or routing_key were not being correctly passed to apply_async when a task is retried.
Simon Engledew vor 12 Jahren
Ursprung
Commit
567e7ed3a7
1 geänderte Dateien mit 1 neuen und 0 gelöschten Zeilen
  1. 1 0
      celery/app/task.py

+ 1 - 0
celery/app/task.py

@@ -554,6 +554,7 @@ class Task(object):
         S = self.subtask_from_request(
             request, args, kwargs,
             countdown=countdown, eta=eta, retries=retries,
+            **options
         )
 
         if max_retries is not None and retries > max_retries: