flakes

celery/concurrency/processes.py

@@ -618,7 +618,7 @@ class TaskPool(BasePool):
                     mark_write_gen_as_active(cor)
                     mark_write_fd_as_active(ready_fd)
                     callback.args = (cor, )  # tricky as we need to pass ref
-                    hub_add((ready_fd, ), cor, WRITE|ERR)
+                    hub_add((ready_fd, ), cor, WRITE | ERR)
 
         def _create_payload(type_, args):
             body = dumps((type_, args), protocol=protocol)
@@ -636,12 +636,12 @@ class TaskPool(BasePool):
             mark_write_gen_as_active(cor)
             mark_write_fd_as_active(fd)
             callback.args = (cor, )
-            hub_add((fd, ), cor, WRITE|ERR)
+            hub_add((fd, ), cor, WRITE | ERR)
         self._pool.send_ack = send_ack
 
         def on_poll_start(hub):
             if outbound:
-                hub_add(diff(active_writes), schedule_writes, WRITE|ERR)
+                hub_add(diff(active_writes), schedule_writes, WRITE | ERR)
         self.on_poll_start = on_poll_start
 
         def quick_put(tup):

celery/tests/app/test_app.py

@@ -25,6 +25,7 @@ from celery.utils.mail import ErrorMail
 
 THIS_IS_A_KEY = 'this is a value'
 
+
 class ObjectConfig(object):
     FOO = 1
     BAR = 2
@@ -386,7 +387,6 @@ class test_App(Case):
         self.assertEqual(self.app.conf['FOO'], 10)
         self.assertEqual(self.app.conf['BAR'], 20)
 
-
     @patch('celery.bin.celery.CeleryCommand.execute_from_commandline')
     def test_start(self, execute):
         self.app.start()

celery/tests/app/test_loaders.py

@@ -12,7 +12,6 @@ from celery.exceptions import (
     NotConfigured,
     CPendingDeprecationWarning,
 )
-from celery.five import items
 from celery.loaders import base
 from celery.loaders import default
 from celery.loaders.app import AppLoader

celery/worker/loops.py

@@ -119,7 +119,7 @@ def asynloop(obj, connection, consumer, strategies, ns, hub, qos,
                             if isinstance(cb, generator):
                                 try:
                                     next(cb)
-                                    hub_add(fileno, cb, WRITE|ERR)
+                                    hub_add(fileno, cb, WRITE | ERR)
                                 except StopIteration:
                                     hub_remove(fileno)
                                 except Exception: