Quellcode durchsuchen

Display PIDs of workers that we are waiting for

Loren Abrams vor 12 Jahren
Ursprung
Commit
5ca3e45d5a
1 geänderte Dateien mit 3 neuen und 2 gelöschten Zeilen
  1. 3 2
      celery/bin/multi.py

+ 3 - 2
celery/bin/multi.py

@@ -275,8 +275,9 @@ class MultiTool(object):
         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()