Bläddra i källkod

Make request.headers available for task.apply. Closes #1874

Ask Solem 11 år sedan
förälder
incheckning
2e63e42646
1 ändrade filer med 1 tillägg och 0 borttagningar
  1. 1 0
      celery/app/task.py

+ 1 - 0
celery/app/task.py

@@ -710,6 +710,7 @@ class Task(object):
                    'loglevel': options.get('loglevel', 0),
                    'callbacks': maybe_list(link),
                    'errbacks': maybe_list(link_error),
+                   'headers': options.get('headers'),
                    'delivery_info': {'is_eager': True}}
         if self.accept_magic_kwargs:
             default_kwargs = {'task_name': task.name,