Sfoglia il codice sorgente

Merge branch '3.1' of github.com:celery/celery into 3.1

Ask Solem 10 anni fa
parent
commit
21c9889abf
1 ha cambiato i file con 2 aggiunte e 1 eliminazioni
  1. 2 1
      celery/app/trace.py

+ 2 - 1
celery/app/trace.py

@@ -337,7 +337,8 @@ def trace_task(task, uuid, args, kwargs, request={}, **opts):
 
 
 def _trace_task_ret(name, uuid, args, kwargs, request={}, app=None, **opts):
-    return trace_task((app or current_app).tasks[name],
+    app = app or current_app
+    return trace_task(app.tasks[name],
                       uuid, args, kwargs, request, app=app, **opts)
 trace_task_ret = _trace_task_ret