Adds Celery.current_task

celery/app/base.py

@@ -27,7 +27,7 @@ from celery import platforms
 from celery.exceptions import AlwaysEagerIgnored
 from celery.loaders import get_loader_cls
 from celery.local import PromiseProxy, maybe_evaluate
-from celery.state import _tls, get_current_app
+from celery.state import _task_stack, _tls, get_current_app
 from celery.utils.functional import first
 from celery.utils.imports import instantiate, symbol_by_name
 
@@ -391,6 +391,10 @@ class Celery(object):
                             limit=self.conf.BROKER_POOL_LIMIT)
         return self._pool
 
+    @property
+    def current_task(self):
+        return _task_stack.top
+
     @cached_property
     def amqp(self):
         """Sending/receiving messages.  See :class:`~celery.app.amqp.AMQP`."""

docs/reference/celery.rst

@@ -36,6 +36,10 @@ Application
 
         Current configuration.
 
+    .. attribute:: current_task
+
+        The instance of the task that is being executed, or :const:`None`.
+
     .. attribute:: amqp
 
         AMQP related functionality: :class:`~@amqp`.