PEP8ify

celery/result.py

@@ -69,8 +69,8 @@ class BaseAsyncResult(object):
 
     def ready(self):
         """Returns ``True`` if the task executed successfully, or raised
-        an exception. If the task is still running, pending, or is waiting for retry
-        then ``False`` is returned.
+        an exception. If the task is still running, pending, or is waiting
+        for retry then ``False`` is returned.
 
         :rtype: bool
 

celery/states.py

@@ -51,5 +51,3 @@ UNREADY_STATES = frozenset([PENDING, STARTED, RETRY])
 EXCEPTION_STATES = frozenset([RETRY, FAILURE])
 
 ALL_STATES = frozenset([PENDING, STARTED, SUCCESS, FAILURE, RETRY])
-
-

celery/tests/test_worker_job.py

@@ -417,4 +417,5 @@ class TestTaskWrapper(unittest.TestCase):
         self._test_on_failure(Exception(u"Бобры атакуют"))
 
     def test_on_failure_utf8_exception(self):
-        self._test_on_failure(Exception(u"Бобры атакуют".encode('utf8')))
+        self._test_on_failure(Exception(
+            u"Бобры атакуют".encode('utf8')))

celery/worker/buckets.py

@@ -174,6 +174,7 @@ class TaskBucket(object):
         return filter(None, chain.from_iterable(izip_longest(*[bucket.items
                                     for bucket in self.buckets.values()])))
 
+
 class FastQueue(Queue):
     """:class:`Queue.Queue` supporting the interface of
     :class:`TokenBucketQueue`."""

celery/worker/control/builtins.py

@@ -80,7 +80,6 @@ def dump_reserved(panel, **kwargs):
     return info
 
 
-
 @Panel.register
 def dump_tasks(panel, **kwargs):
 

celery/worker/scheduler.py

@@ -85,6 +85,7 @@ class Scheduler(object):
     def info(self):
         return ({"eta": eta, "priority": priority, "item": item}
                     for eta, priority, item, _ in self.queue)
+
     @property
     def queue(self):
         events = list(self._queue)