Browse Source

Display PIDs of workers that we are waiting for

Loren Abrams 12 years ago
parent
commit
f390f298c3
1 changed files with 3 additions and 2 deletions
  1. 3 2
      celery/bin/celeryd_multi.py

+ 3 - 2
celery/bin/celeryd_multi.py

@@ -271,8 +271,9 @@ class MultiTool(object):
         def note_waiting():
             left = len(P)
             if left:
-                self.note(self.colored.blue('> Waiting for %s %s...' % (
-                    left, pluralize(left, 'node'))), newline=False)
+                pids = ', '.join(str(pid) for _, _, pid in P)
+                self.note(self.colored.blue('> Waiting for %s %s -> %s...' % (
+                    left, pluralize(left, 'node'), pids)), newline=False)
 
         if retry:
             note_waiting()