Display PIDs of workers that we are waiting for

odyss009 · Dec 19, 2012 · 5ca3e45 · 5ca3e45
1 parent 10bb5a6
commit 5ca3e45
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/celery/bin/multi.py b/celery/bin/multi.py
@@ -275,8 +275,9 @@ def on_down(node):
         def note_waiting():
             left = len(P)
             if left:
-                self.note(self.colored.blue('> Waiting for {0} {1}...'.format(
-                    left, pluralize(left, 'node'))), newline=False)
+                pids = ', '.join(str(pid) for _, _, pid in P)
+                self.note(self.colored.blue('> Waiting for {0} {1} -> {2}...'.format(
+                    left, pluralize(left, 'node'), pids)), newline=False)
 
         if retry:
             note_waiting()