PEP8ify + pyflakes

celery/backends/amqp.py

@@ -1,5 +1,4 @@
 # -*- coding: utf-8 -*-
-import os
 import socket
 import threading
 import time

celery/events/__init__.py

@@ -68,7 +68,6 @@ class EventDispatcher(object):
             self.enable()
 
     def enable(self):
-        conf = self.app.conf
         self.enabled = True
         channel = self.channel or self.connection.channel()
         self.publisher = Producer(channel, exchange=event_exchange,

celery/events/state.py

@@ -69,7 +69,6 @@ class Task(Element):
     merge_rules = {states.RECEIVED: ("name", "args", "kwargs",
                                      "retries", "eta", "expires")}
 
-
     #: meth:`info` displays these fields by default.
     _info_fields = ("args", "kwargs", "retries", "result",
                     "eta", "runtime", "expires", "exception")

celery/tests/test_app/test_app.py

@@ -93,7 +93,7 @@ class test_App(unittest.TestCase):
         self.assertTrue(self.app.conf.MOMENT_TO_STOP)
         self.assertEqual(self.app.conf.CALL_ME_BACK, 123456789)
         self.assertFalse(self.app.conf.WANT_ME_TO)
-        self.assertTrue(self.app.conf.UNDERSTAND_ME)        
+        self.assertTrue(self.app.conf.UNDERSTAND_ME)
 
     def test_config_from_cmdline(self):
         cmdline = [".always_eager=no",
@@ -118,7 +118,7 @@ class test_App(unittest.TestCase):
 
         self.app.config_from_object(Object(CELERY_BACKEND="set_by_us"))
         self.assertEqual(self.app.conf.CELERY_RESULT_BACKEND, "set_by_us")
-        
+
     def test_setting_BROKER_TRANSPORT_OPTIONS(self):
 
         _args = {'foo': 'bar', 'spam': 'baz'}
@@ -127,7 +127,7 @@ class test_App(unittest.TestCase):
         self.assertEqual(self.app.conf.BROKER_TRANSPORT_OPTIONS, {})
 
         self.app.config_from_object(Object(BROKER_TRANSPORT_OPTIONS=_args))
-        self.assertEqual(self.app.conf.BROKER_TRANSPORT_OPTIONS, _args)        
+        self.assertEqual(self.app.conf.BROKER_TRANSPORT_OPTIONS, _args)
 
     def test_Windows_log_color_disabled(self):
         self.app.IS_WINDOWS = True

celery/worker/mediator.py

@@ -48,7 +48,6 @@ class Mediator(threading.Thread):
             "Mediator: Running callback for task: %s[%s]" % (
                 task.task_name, task.task_id))
 
-
         try:
             self.callback(task)
         except Exception, exc:

contrib/release/flakesignore.txt

@@ -72,4 +72,4 @@ celery/utils/__init__.py:16: 'cached_property' imported but unused
 celery/beat.py:16: redefinition of unused 'multiprocessing' from line 14
 celery/worker/state.py:62: redefinition of function 'task_reserved' from line 36
 celery/worker/state.py:68: redefinition of function 'task_ready' from line 47
-
+celery/beat.py:11: redefinition of unused 'multiprocessing' from line 9