Sfoglia il codice sorgente

Task v1 requests missing group header. Closes #2297

Ask Solem 10 anni fa
parent
commit
728548d1be
1 ha cambiato i file con 4 aggiunte e 0 eliminazioni
  1. 4 0
      celery/worker/strategy.py

+ 4 - 0
celery/worker/strategy.py

@@ -41,6 +41,10 @@ def proto1_to_proto2(message, body):
             'Task keyword arguments must be a mapping',
         )
     body['headers'] = message.headers
+    try:
+        body['group'] = body['taskset']
+    except KeyError:
+        pass
     return (args, kwargs), body, True, body.get('utc', True)