PEP8ify + pyflakes

celery/backends/cassandra.py

@@ -58,8 +58,8 @@ class CassandraBackend(BaseDictBackend):
 
         if not pycassa:
             raise ImproperlyConfigured(
-                    "You need to install the pycassa library to use the "
-                    "Cassandra backend. See https://github.com/pycassa/pycassa")
+                "You need to install the pycassa library to use the "
+                "Cassandra backend. See https://github.com/pycassa/pycassa")
 
         self.servers = servers or \
                         self.app.conf.get("CASSANDRA_SERVERS", self.servers)
@@ -77,7 +77,8 @@ class CassandraBackend(BaseDictBackend):
         write_cons = self.app.conf.get("CASSANDRA_WRITE_CONSISTENCY",
                                        "LOCAL_QUORUM")
         try:
-            self.read_consistency = getattr(pycassa.ConsistencyLevel, read_cons)
+            self.read_consistency = getattr(pycassa.ConsistencyLevel,
+                                            read_cons)
         except AttributeError:
             self.read_consistency = pycassa.ConsistencyLevel.LOCAL_QUORUM
         try:

contrib/release/flakesignore.txt

@@ -69,3 +69,7 @@ celery/tests/test_task/test_task_http.py:9: redefinition of unused 'addinfourl'
 celery/tests/test_task/test_task_http.py:13: redefinition of unused 'contextmanager' from line 11
 celery/backends/pyredis.py:90: redefinition of function 'client' from line 83
 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
+

docs/conf.py

@@ -8,8 +8,6 @@ os.environ["GEVENT_NOPATCH"] = "yes"
 os.environ["EVENTLET_NOPATCH"] = "yes"
 os.environ["CELERY_LOADER"] = "default"
 
-
-
 this = os.path.dirname(os.path.abspath(__file__))
 
 # If your extensions are in another directory, add it here. If the directory