flakes

celery/app/base.py

@@ -35,7 +35,6 @@ from celery.loaders import get_loader_cls
 from celery.local import PromiseProxy, maybe_evaluate
 from celery.utils.functional import first, maybe_list
 from celery.utils.imports import instantiate, symbol_by_name
-from celery.utils.log import ensure_process_aware_logger
 from celery.utils.objects import mro_lookup
 
 from .annotations import prepare as prepare_annotations

celery/app/trace.py

@@ -263,8 +263,8 @@ def build_tracer(name, task, loader=None, hostname=None, store_errors=True,
                 try:
                     if postrun_receivers:
                         send_postrun(sender=task, task_id=uuid, task=task,
-                                    args=args, kwargs=kwargs,
-                                    retval=retval, state=state)
+                                     args=args, kwargs=kwargs,
+                                     retval=retval, state=state)
                 finally:
                     pop_task()
                     pop_request()

celery/tests/case.py

@@ -138,6 +138,7 @@ class Mock(mock.Mock):
         for attr_name, attr_value in items(attrs):
             setattr(self, attr_name, attr_value)
 
+
 class _ContextMock(Mock):
     """Dummy class implementing __enter__ and __exit__
     as the with statement requires these to be implemented
@@ -161,7 +162,6 @@ def ContextMock(*args, **kwargs):
     return obj
 
 
-
 def skip_unless_module(module):
 
     def _inner(fun):

celery/tests/worker/test_consumer.py

@@ -256,6 +256,7 @@ def _amqp_connection():
     connection.return_value.transport.driver_type = 'amqp'
     return connection
 
+
 class test_Gossip(AppCase):
 
     def test_init(self):