Explorar el Código

Prefork: Fixes task execution when using pickle and protocol1. Closes #2942

Ask Solem hace 9 años
padre
commit
5ae95c8a01
Se han modificado 1 ficheros con 2 adiciones y 2 borrados
  1. 2 2
      celery/app/trace.py

+ 2 - 2
celery/app/trace.py

@@ -486,7 +486,7 @@ def _trace_task_ret(name, uuid, request, body, content_type,
             body, content_type, content_encoding, accept=accept,
             body, content_type, content_encoding, accept=accept,
         )
         )
     else:
     else:
-        args, kwargs = body
+        args, kwargs, embed = body
     hostname = socket.gethostname()
     hostname = socket.gethostname()
     request.update({
     request.update({
         'args': args, 'kwargs': kwargs,
         'args': args, 'kwargs': kwargs,
@@ -508,7 +508,7 @@ def _fast_trace_task(task, uuid, request, body, content_type,
             body, content_type, content_encoding, accept=accept,
             body, content_type, content_encoding, accept=accept,
         )
         )
     else:
     else:
-        args, kwargs = body
+        args, kwargs, embed = body
     request.update({
     request.update({
         'args': args, 'kwargs': kwargs,
         'args': args, 'kwargs': kwargs,
         'hostname': hostname, 'is_eager': False,
         'hostname': hostname, 'is_eager': False,