PEP8ify

celery/signals.py

@@ -85,8 +85,6 @@ Provides arguments:
 task_postrun = Signal(providing_args=[
                         "task_id", "task", "args", "kwargs", "retval"])
 
-
-
 """
 
 .. data:: worker_init

celery/tests/test_datastructures.py

@@ -128,5 +128,3 @@ class TestLimitedSet(unittest.TestCase):
         items = "foo", "bar"
         map(s.add, items)
         self.assertTrue(repr(s).startswith("LimitedSet("))
-
-

celery/tests/test_worker.py

@@ -146,7 +146,8 @@ class TestCarrotListener(unittest.TestCase):
                            send_events=False)
         backend = MockBackend()
         id = gen_unique_id()
-        c = create_message(backend, control={"command": "revoke", "task_id": id})
+        c = create_message(backend, control={"command": "revoke",
+                                             "task_id": id})
         t = create_message(backend, task=foo_task.name, args=[2, 4, 8],
                            kwargs={}, id=id)
         l.event_dispatcher = MockEventDispatcher()
@@ -157,7 +158,6 @@ class TestCarrotListener(unittest.TestCase):
         l.receive_message(t.decode(), t)
         self.assertTrue(ready_queue.empty())
 
-
     def test_receieve_message_not_registered(self):
         l = CarrotListener(self.ready_queue, self.eta_scheduler, self.logger,
                           send_events=False)

celery/tests/test_worker_scheduler.py

@@ -45,4 +45,3 @@ class TestScheduler(unittest.TestCase):
         sched = Scheduler(ready_queue)
 
         self.assertTrue(iter(sched).next() is None)
-