flake8

celery/app/amqp.py

@@ -11,7 +11,7 @@
 """
 from __future__ import absolute_import
 
-from datetime import datetime, timedelta
+from datetime import timedelta
 
 from kombu import BrokerConnection, Exchange
 from kombu import compat as messaging

celery/app/base.py

@@ -17,7 +17,6 @@ import platform as _platform
 
 from contextlib import contextmanager
 from copy import deepcopy
-from datetime import datetime
 from functools import wraps
 
 from kombu.clocks import LamportClock

celery/backends/cassandra.py

@@ -12,8 +12,6 @@ except ImportError:
 import socket
 import time
 
-from datetime import datetime
-
 from .. import states
 from ..exceptions import ImproperlyConfigured
 from ..utils.timeutils import maybe_timedelta, timedelta_seconds

celery/backends/database.py

@@ -1,8 +1,6 @@
 # -*- coding: utf-8 -*-
 from __future__ import absolute_import
 
-from datetime import datetime
-
 from .. import states
 from ..db.models import Task, TaskSet
 from ..db.session import ResultSession

celery/beat.py

@@ -23,8 +23,6 @@ try:
 except ImportError:
     multiprocessing = None  # noqa
 
-from datetime import datetime
-
 from . import __version__
 from . import platforms
 from . import registry

celery/schedules.py

@@ -14,7 +14,7 @@ from __future__ import absolute_import
 
 import re
 
-from datetime import datetime, timedelta
+from datetime import timedelta
 from dateutil.relativedelta import relativedelta
 
 from . import current_app

celery/tests/test_utils/__init__.py

@@ -1,8 +1,6 @@
 from __future__ import absolute_import
 from __future__ import with_statement
 
-import pickle
-
 from celery import utils
 from celery.utils import promise, mpromise
 from celery.utils.threads import bgThread

celery/utils/__init__.py

@@ -34,9 +34,7 @@ from kombu.utils.functional import promise, maybe_promise       # noqa
 uuid = gen_unique_id
 
 from ..exceptions import CPendingDeprecationWarning, CDeprecationWarning
-
 from .compat import StringIO
-from .encoding import safe_repr as _safe_repr
 
 LOG_LEVELS = dict(logging._levelNames)
 LOG_LEVELS["FATAL"] = logging.FATAL