Переглянути джерело

Adds priority to task.request.delivery_info. Closes #807

Ask Solem 12 роки тому
батько
коміт
0070506559
1 змінених файлів з 1 додано та 0 видалено
  1. 1 0
      celery/worker/job.py

+ 1 - 0
celery/worker/job.py

@@ -130,6 +130,7 @@ class Request(object):
         self.delivery_info = {
         self.delivery_info = {
             'exchange': delivery_info.get('exchange'),
             'exchange': delivery_info.get('exchange'),
             'routing_key': delivery_info.get('routing_key'),
             'routing_key': delivery_info.get('routing_key'),
+            'priority': delivery_info.get('priority'),
         }
         }
 
 
         self.request_dict = body
         self.request_dict = body