ADD: Indico Patch

.gitignore

@@ -31,3 +31,4 @@ htmlcov/
 coverage.xml
 test.db
 pip-wheel-metadata/
+.vscode/

celery/app/task.py

@@ -1004,6 +1004,12 @@ def add_trail(self, result):
         return result
 
     def push_request(self, *args, **kwargs):
+        # indico
+        # we want access to args & kwargs in our copied context
+        # TODO: consider making a copy - need to make sure arguments are small enough
+        # to avoid dup mem.
+        self.request.args = args
+        self.request.kwargs = kwargs
         self.request_stack.push(Context(*args, **kwargs))
 
     def pop_request(self):

celery/backends/base.py

@@ -238,6 +238,12 @@ def chord_error_from_stack(self, callback, exc=None):
         # need below import for test for some crazy reason
         from celery import group  # pylint: disable
         app = self.app
+
+        # indico
+        # Revoke causes callbacks id to be None
+        if callback.id is None and callback.tasks:
+            callback.id = callback.tasks[0].id
+
         try:
             backend = app._tasks[callback.task].backend
         except KeyError: