flake8

celery/app/task.py

@@ -12,8 +12,6 @@ from __future__ import with_statement
 import os
 import sys
 
-from kombu.utils import cached_property
-
 from celery import current_app
 from celery import states
 from celery.__compat__ import class_property

celery/bin/celery.py

@@ -37,7 +37,8 @@ Type '%(prog_name)s <command> --help' for help using a specific command.
 commands = {}
 
 command_classes = (
-    ('Main', ['worker', 'events', 'beat', 'shell', 'multi', 'amqp', 'help'], 'green'),
+    ('Main', ['worker', 'events', 'beat',
+              'shell', 'multi', 'amqp', 'help'], 'green'),
     ('Remote Control', ['status', 'inspect', 'control'], 'blue'),
     ('Utils', ['purge', 'list', 'migrate', 'apply', 'result', 'report'], None),
 )

celery/tests/tasks/test_http.py

@@ -2,8 +2,6 @@
 from __future__ import absolute_import
 from __future__ import with_statement
 
-import logging
-
 from contextlib import contextmanager
 from functools import wraps
 try:

celery/worker/consumer.py

@@ -183,9 +183,7 @@ class Component(StartStopComponent):
 
 
 class QoS(object):
-    """Quality of Service for Channel.
-
-    For thread-safe increment/decrement of a channels prefetch count value.
+    """Thread safe increment/decrement of a channels prefetch_count.
 
     :param consumer: A :class:`kombu.messaging.Consumer` instance.
     :param initial_value: Initial prefetch count value.
@@ -220,7 +218,6 @@ class QoS(object):
         with self._mutex:
             if self.value:
                 self.value -= n
-                print("DECREMENT %r" % (self.value, ))
         return self.value
 
     def set(self, pcount):
@@ -239,7 +236,6 @@ class QoS(object):
     def update(self):
         """Update prefetch count with current value."""
         with self._mutex:
-            print("SET: %r " % (self.value, ))
             return self.set(self.value)