Browse Source

celery inspect stats contains worker pid

Mher Movsisyan 12 years ago
parent
commit
d19dc5839a
1 changed files with 5 additions and 1 deletions
  1. 5 1
      celery/worker/control.py

+ 5 - 1
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