PEP8ify + pyflakes

celery/app/amqp.py

@@ -226,7 +226,7 @@ class TaskPublisher(messaging.Publisher):
         if taskset_id:
             body["taskset"] = taskset_id
         if chord:
-        	body["chord"] = chord
+            body["chord"] = chord
 
         send = self.send
         if retry is None and self.retry or retry:

celery/backends/amqp.py

@@ -272,4 +272,3 @@ class AMQPBackend(BaseDictBackend):
     def delete_taskset(self, taskset_id):
         raise NotImplementedError(
                 "delete_taskset is not supported by this backend.")
-

celery/task/base.py

@@ -88,7 +88,7 @@ class TaskType(type):
             except KeyError:
                 # Fix for manage.py shell_plus (Issue #366).
                 module_name = task_module
-            attrs["name"] = '.'.join([task_module, name])
+            attrs["name"] = '.'.join([module_name, name])
 
         # Because of the way import happens (recursively)
         # we may or may not be the first time the task tries to register

celery/tests/test_backends/test_amqp.py

@@ -286,7 +286,7 @@ class test_AMQPBackend(unittest.TestCase):
     def test_restore_taskset(self):
         self.assertRaises(NotImplementedError,
                           self.create_backend().restore_taskset, "x")
-    
+
     def test_delete_taskset(self):
         self.assertRaises(NotImplementedError,
                           self.create_backend().delete_taskset, "x")

celery/tests/test_backends/test_base.py

@@ -17,6 +17,7 @@ from celery.utils import gen_unique_id
 
 from celery.tests.utils import unittest
 
+
 class wrapobject(object):
 
     def __init__(self, *args, **kwargs):

celery/worker/job.py

@@ -136,7 +136,6 @@ class WorkerTaskTrace(TaskTrace):
                 logger.error("Process cleanup failed: %r" % (exc, ),
                              exc_info=sys.exc_info())
 
-
     def handle_success(self, retval, *args):
         """Handle successful execution."""
         if not self.task.ignore_result:

contrib/release/flakesignore.txt

@@ -30,7 +30,7 @@ celery/utils/mail.py:(.+?) redefinition of unused 'MIMEText'
 celery/utils/__init__.py:(.+?) 'gen_unique_id' imported but unused
 celery/events/cursesmon.py:(.+?): local variable 'consumer' is assigned to but never used
 celery/tests/utils.py:(.+?): 'unittest' imported but unused
-celery/tests/utils.py:(.+?): redefinition of unused 'builtins' from line 12
+celery/tests/utils.py:(.+?): redefinition of unused 'builtins' from line \d+
 celery/tests/utils.py:(.+?): redefinition of unused 'StringIO' from line 16
 celery/utils/compat.py:(.+?): redefinition of unused 'UserList' from line 5
 celery/utils/compat.py:(.+?): 'UserList' imported but unused
@@ -73,6 +73,6 @@ 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
 celery/utils/compat.py:498: redefinition of unused 'WatchedFileHandler' from line 496
-celery/backends/pyredis.py:103: redefinition of function 'client' from line 96
+celery/backends/pyredis.py:(.+?): redefinition of function 'client' from line .+?$
 celery/task/__init__.py:7: 'chord' imported but unused