celery inspect stats contains worker pid

treeder · Jan 21, 2013 · d19dc58 · d19dc58
1 parent 8f3ddf0
commit d19dc58
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/celery/worker/control.py b/celery/worker/control.py
@@ -8,7 +8,10 @@
 """
 from __future__ import absolute_import
 
+import os
+
 from datetime import datetime
+from future_builtins import map
 
 from kombu.utils.encoding import safe_repr
 
@@ -193,7 +196,8 @@ def stats(panel, **kwargs):
     return {'total': state.total_count,
             'consumer': panel.consumer.info,
             'pool': panel.consumer.pool.info,
-            'autoscaler': asinfo}
+            'autoscaler': asinfo,
+            'pid': os.getpid()}
 
 
 @Panel.register