flakes

celery/app/base.py

@@ -13,7 +13,7 @@ import warnings
 from collections import deque
 from contextlib import contextmanager
 from copy import deepcopy
-from functools import reduce, wraps
+from functools import wraps
 from operator import attrgetter
 from threading import Lock
 

celery/events/__init__.py

@@ -18,7 +18,7 @@ from collections import deque
 from contextlib import contextmanager
 from copy import copy
 
-from kombu import eventloop, Exchange, Queue, Consumer, Producer
+from kombu import Exchange, Queue, Producer
 from kombu.mixins import ConsumerMixin
 from kombu.utils import cached_property
 

celery/utils/mail.py

@@ -13,10 +13,8 @@ import traceback
 import warnings
 
 from email.mime.text import MIMEText
-from future_builtins import map
 
 from .functional import maybe_list
-from .imports import symbol_by_name
 
 
 class SendmailWarning(UserWarning):

celery/worker/control.py

@@ -9,7 +9,6 @@
 from __future__ import absolute_import
 
 from future_builtins import map
-from datetime import datetime
 
 from kombu.utils.encoding import safe_repr
 

docs/internals/guide.rst

@@ -91,7 +91,7 @@ as this means that they can be set by either instantiation or inheritance.
 
     class Producer(object):
         active = True
-        serializer = "json"
+        serializer = 'json'
 
         def __init__(self, serializer=None):
             self.serializer = serializer or self.serializer
@@ -104,13 +104,13 @@ A subclass can change the default value:
 .. code-block:: python
 
     TaskProducer(Producer):
-        serializer = "pickle"
+        serializer = 'pickle'
 
 and the value can be set at instantiation:
 
 .. code-block:: python
 
-    >>> producer = TaskProducer(serializer="msgpack")
+    >>> producer = TaskProducer(serializer='msgpack')
 
 Exceptions
 ~~~~~~~~~~
@@ -220,7 +220,7 @@ from a module in the project, this module could look something like this:
     from celery import Celery
 
     celery = Celery()
-    celery.config_from_object(BROKER_URL="amqp://")
+    celery.config_from_object(BROKER_URL='amqp://')
 
 
 Module Overview