Explorar el Código

Do not output stupid "purge: Erased 0 message from queue" log message

Ask Solem hace 11 años
padre
commit
35747fb2b9
Se han modificado 1 ficheros con 3 adiciones y 2 borrados
  1. 3 2
      celery/apps/worker.py

+ 3 - 2
celery/apps/worker.py

@@ -162,8 +162,9 @@ class Worker(WorkController):
 
     def purge_messages(self):
         count = self.app.control.purge()
-        print('purge: Erased {0} {1} from the queue.\n'.format(
-            count, pluralize(count, 'message')))
+        if count:
+            print('purge: Erased {0} {1} from the queue.\n'.format(
+                count, pluralize(count, 'message')))
 
     def tasklist(self, include_builtins=True, sep='\n', int_='celery.'):
         return sep.join(