Adds the current worker `hostname` to the task context. Closes #460

celery/app/task/__init__.py

@@ -20,6 +20,7 @@ class Context(threading.local):
     # Default context
     logfile = None
     loglevel = None
+    hostname = None
     id = None
     args = None
     kwargs = None

celery/worker/job.py

@@ -305,6 +305,7 @@ class TaskRequest(object):
 
     def get_instance_attrs(self, loglevel, logfile):
         return {"logfile": logfile, "loglevel": loglevel,
+                "hostname": self.hostname,
                 "id": self.task_id, "taskset": self.taskset_id,
                 "retries": self.retries, "is_eager": False,
                 "delivery_info": self.delivery_info, "chord": self.chord}

docs/userguide/tasks.rst

@@ -67,6 +67,8 @@ attributes:
 
 :loglevel: The current log level used.
 
+:hostname: Hostname of the worker instance executing the task.
+
 :delivery_info: Additional message delivery information. This is a mapping
                 containing the exchange and routing key used to deliver this
                 task.  Used by e.g. :meth:`~celery.task.base.BaseTask.retry`