Removes __future__ imports

celery/__init__.py

@@ -5,9 +5,6 @@
 # :copyright: (c) 2009 - 2012 Ask Solem and individual contributors,
 #                 All rights reserved.
 # :license:   BSD (3 Clause), see LICENSE for more details.
-
-from __future__ import absolute_import, print_function, unicode_literals
-
 import os
 import re
 import sys
@@ -168,7 +165,4 @@ old_module, new_module = five.recreate_module(  # pragma: no cover
     version_info=version_info,
     maybe_patch_concurrency=maybe_patch_concurrency,
     _find_option_with_arg=_find_option_with_arg,
-    absolute_import=absolute_import,
-    unicode_literals=unicode_literals,
-    print_function=print_function,
 )

celery/__main__.py

@@ -1,6 +1,4 @@
 """Entry-point for the :program:`celery` umbrella command."""
-from __future__ import absolute_import, print_function, unicode_literals
-
 import sys
 
 from . import maybe_patch_concurrency

celery/_state.py

@@ -6,8 +6,6 @@ like the ``current_app``, and ``current_task``.
 
 This module shouldn't be used directly.
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 import os
 import sys
 import threading

celery/app/__init__.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Celery Application."""
-from __future__ import absolute_import, print_function, unicode_literals
-
 import os
 
 from celery.local import Proxy

celery/app/amqp.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Sending/Receiving Messages (Kombu integration)."""
-from __future__ import absolute_import, unicode_literals
-
 import numbers
 
 from collections import Mapping, namedtuple

celery/app/annotations.py

@@ -7,8 +7,6 @@ in the configuration.
 This prepares and performs the annotations in the
 :setting:`task_annotations` setting.
 """
-from __future__ import absolute_import, unicode_literals
-
 from celery.utils.functional import firstmethod, mlazy
 from celery.utils.imports import instantiate
 

celery/app/base.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Actual App instance implementation."""
-from __future__ import absolute_import, unicode_literals
-
 import os
 import threading
 import warnings

celery/app/builtins.py

@@ -3,8 +3,6 @@
 
 The built-in tasks are always available in all app instances.
 """
-from __future__ import absolute_import, unicode_literals
-
 from celery._state import connect_on_app_finalize
 from celery.utils.log import get_logger
 

celery/app/control.py

@@ -4,8 +4,6 @@
 Client for worker remote control commands.
 Server implementation is in :mod:`celery.worker.control`.
 """
-from __future__ import absolute_import, unicode_literals
-
 import warnings
 
 from billiard.common import TERM_SIGNAME

celery/app/defaults.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Configuration introspection and defaults."""
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from collections import deque, namedtuple

celery/app/log.py

@@ -7,8 +7,6 @@ Sets up logging for the worker and other programs,
 redirects standard outs, colors log output, patches logging
 related compatibility fixes, and so on.
 """
-from __future__ import absolute_import, unicode_literals
-
 import logging
 import os
 import sys

celery/app/registry.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Registry of available tasks."""
-from __future__ import absolute_import, unicode_literals
-
 import inspect
 
 from importlib import import_module

celery/app/routes.py

@@ -3,8 +3,6 @@
 
 Contains utilities for working with task routers, (:setting:`task_routes`).
 """
-from __future__ import absolute_import, unicode_literals
-
 import re
 import string
 

celery/app/task.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Task implementation: request context and the task base class."""
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from billiard.einfo import ExceptionInfo

celery/app/trace.py

@@ -4,8 +4,6 @@
 This module defines how the task execution is traced:
 errors are recorded, handlers are applied and so on.
 """
-from __future__ import absolute_import, unicode_literals
-
 # ## ---
 # This is the heart of the worker, the inner loop so to speak.
 # It used to be split up into nice little classes and methods,

celery/app/utils.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """App utilities: Compat settings, bug-report tool, pickling apps."""
-from __future__ import absolute_import, unicode_literals
-
 import os
 import platform as _platform
 import re

celery/apps/beat.py

@@ -5,8 +5,6 @@ It does everything necessary to run that module
 as an actual application, like installing signal handlers
 and so on.
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 import numbers
 import socket
 import sys

celery/apps/worker.py

@@ -5,8 +5,6 @@ It does everything necessary to run that module
 as an actual application, like installing signal handlers,
 platform tweaks, and so on.
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 import logging
 import os
 import platform as _platform

celery/backends/__init__.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Backend abstract factory (...did I just say that?) and alias definitions."""
-from __future__ import absolute_import, unicode_literals
-
 import sys
 import types
 

celery/backends/amqp.py

@@ -3,8 +3,6 @@
 
 This backend publishes results as messages, one queue per task(!)
 """
-from __future__ import absolute_import, unicode_literals
-
 from .rpc import BaseRPCBackend
 
 from celery.utils import deprecated

celery/backends/async.py

@@ -1,6 +1,4 @@
 """Async I/O backend support utilities."""
-from __future__ import absolute_import, unicode_literals
-
 import socket
 
 from collections import deque

celery/backends/base.py

@@ -6,8 +6,6 @@
 - :class:`KeyValueStoreBackend` is a common base class
     using K/V semantics like _get and _put.
 """
-from __future__ import absolute_import, unicode_literals
-
 import sys
 import time
 

celery/backends/cache.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Memcached and in-memory cache result backend."""
-from __future__ import absolute_import, unicode_literals
-
 from kombu.utils import cached_property
 from kombu.utils.encoding import bytes_to_str, ensure_bytes
 

celery/backends/cassandra.py

@@ -1,6 +1,10 @@
 # -* coding: utf-8 -*-
 """Apache Cassandra result store backend using the DataStax driver."""
-from __future__ import absolute_import, unicode_literals
+from celery import states
+from celery.exceptions import ImproperlyConfigured
+from celery.utils.log import get_logger
+
+from .base import BaseBackend
 
 try:  # pragma: no cover
     import cassandra
@@ -9,11 +13,6 @@ try:  # pragma: no cover
 except ImportError:  # pragma: no cover
     cassandra = None   # noqa
 
-from celery import states
-from celery.exceptions import ImproperlyConfigured
-from celery.utils.log import get_logger
-from .base import BaseBackend
-
 __all__ = ['CassandraBackend']
 
 logger = get_logger(__name__)

celery/backends/consul.py

@@ -4,8 +4,6 @@
 - :class:`ConsulBackend` implements KeyValueStoreBackend to store results
     in the key-value store of Consul.
 """
-from __future__ import absolute_import, unicode_literals
-
 from kombu.utils.url import parse_url
 
 from celery.exceptions import ImproperlyConfigured

celery/backends/couchbase.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Couchbase result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 import logging
 
 try:

celery/backends/couchdb.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """CouchDB result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 from kombu.utils.url import _parse_url
 
 from celery.exceptions import ImproperlyConfigured

celery/backends/database/__init__.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """SQLAlchemy result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 import logging
 
 from contextlib import contextmanager

celery/backends/database/models.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Database models used by the SQLAlchemy result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 from datetime import datetime
 
 import sqlalchemy as sa

celery/backends/database/session.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """SQLAlchemy session."""
-from __future__ import absolute_import, unicode_literals
-
 from sqlalchemy import create_engine
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy.orm import sessionmaker

celery/backends/elasticsearch.py

@@ -1,7 +1,5 @@
 # -* coding: utf-8 -*-
 """Elasticsearch result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 from datetime import datetime
 
 from kombu.utils.url import _parse_url

celery/backends/filesystem.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """File-system result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 from kombu.utils.encoding import ensure_bytes
 
 from celery import uuid

celery/backends/mongodb.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """MongoDB result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 from datetime import datetime, timedelta
 
 from kombu.utils import cached_property

celery/backends/redis.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Redis result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 from functools import partial
 
 from kombu.utils import cached_property, retry_over_time

celery/backends/riak.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Riak result store backend."""
-from __future__ import absolute_import, unicode_literals
-
 try:
     import riak
     from riak import RiakClient

celery/backends/rpc.py

@@ -3,8 +3,6 @@
 
 RPC-style result backend, using reply-to and one queue per client.
 """
-from __future__ import absolute_import, unicode_literals
-
 from kombu import Consumer, Exchange, Producer, Queue
 from kombu.common import maybe_declare
 from kombu.utils import cached_property, register_after_fork

celery/beat.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """The periodic task scheduler."""
-from __future__ import absolute_import, unicode_literals
-
 import errno
 import heapq
 import os

celery/bin/__init__.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from .base import Option
 
 __all__ = ['Option']

celery/bin/amqp.py

@@ -3,8 +3,6 @@
 
 .. program:: celery amqp
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 import cmd
 import sys
 import shlex

celery/bin/base.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Base command-line interface."""
-from __future__ import absolute_import, print_function, unicode_literals
-
 import os
 import random
 import re

celery/bin/beat.py

@@ -64,8 +64,6 @@
 
     Executable to use for the detached process.
 """
-from __future__ import absolute_import, unicode_literals
-
 from functools import partial
 
 from celery.platforms import detached, maybe_drop_privileges

celery/bin/celery.py

@@ -254,8 +254,6 @@ in any command that also has a `--detach` option.
 
     Destination routing key (defaults to the queue routing key).
 """
-from __future__ import absolute_import, unicode_literals, print_function
-
 import codecs
 import numbers
 import os

celery/bin/celeryd_detach.py

@@ -5,8 +5,6 @@ Using :func:`os.execv` as forking and multiprocessing
 leads to weird issues (it was a long time ago now, but it
 could have something to do with the threading mutex bug)
 """
-from __future__ import absolute_import, unicode_literals
-
 import celery
 import os
 import sys

celery/bin/events.py

@@ -65,8 +65,6 @@
 
     Executable to use for the detached process.
 """
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from functools import partial

celery/bin/graph.py

@@ -3,8 +3,6 @@
 
 .. program:: celery graph
 """
-from __future__ import absolute_import, unicode_literals
-
 from operator import itemgetter
 
 from celery.utils.graph import DependencyGraph, GraphFormatter

celery/bin/logtool.py

@@ -3,9 +3,6 @@
 
 .. program:: celery logtool
 """
-
-from __future__ import absolute_import, unicode_literals
-
 import re
 
 from collections import Counter

celery/bin/multi.py

@@ -93,9 +93,6 @@ Examples
     celery worker -n baz@myhost -c 10
     celery worker -n xuzzy@myhost -c 3
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
-import errno
 import os
 import shlex
 import signal

celery/bin/worker.py

@@ -161,8 +161,6 @@ The :program:`celery worker` command (previously known as ``celeryd``)
 
     Executable to use for the detached process.
 """
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from optparse import OptionGroup

celery/bootsteps.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """A directed acyclic graph of reusable components."""
-from __future__ import absolute_import, unicode_literals
-
 from collections import deque
 from threading import Event
 

celery/canvas.py

@@ -5,8 +5,6 @@
 
     You should import these from :mod:`celery` and not this module.
 """
-from __future__ import absolute_import, unicode_literals
-
 from collections import MutableSequence, deque
 from copy import deepcopy
 from functools import partial as _partial, reduce

celery/concurrency/__init__.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Pool implementation abstract factory, and alias definitions."""
-from __future__ import absolute_import, unicode_literals
-
 # Import from kombu directly as it's used
 # early in the import stage, where celery.utils loads
 # too much (e.g. for eventlet patching)

celery/concurrency/asynpool.py

@@ -13,7 +13,7 @@ This code deals with three major challenges:
 #. Sending jobs to the processes and receiving results back.
 #. Safely shutting down this system.
 """
-from __future__ import absolute_import, unicode_literals
+from __future__ import generator_stop
 
 import errno
 import gc
@@ -849,6 +849,8 @@ class AsynPool(_pool.Pool):
                         yield
                     else:
                         errors = 0
+            except StopIteration:
+                pass
             finally:
                 hub_remove(fd)
                 write_stats[proc.index] += 1

celery/concurrency/base.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Base Execution Pool"""
-from __future__ import absolute_import, unicode_literals
-
 import logging
 import os
 import sys

celery/concurrency/eventlet.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Eventlet execution pool."""
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from time import time

celery/concurrency/gevent.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Gevent execution pool."""
-from __future__ import absolute_import, unicode_literals
-
 from time import time
 
 try:

celery/concurrency/prefork.py

@@ -3,8 +3,6 @@
 
 Pool implementation using :mod:`multiprocessing`.
 """
-from __future__ import absolute_import, unicode_literals
-
 import os
 
 from billiard.common import REMAP_SIGTERM, TERM_SIGNAME

celery/concurrency/solo.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Single-threaded execution pool."""
-from __future__ import absolute_import, unicode_literals
-
 import os
 
 from .base import BasePool, apply_target

celery/contrib/abortable.py

@@ -28,8 +28,6 @@ In the consumer:
 
 .. code-block:: python
 
-    from __future__ import absolute_import
-
     from celery.contrib.abortable import AbortableTask
     from celery.utils.log import get_task_logger
 
@@ -57,8 +55,6 @@ In the producer:
 
 .. code-block:: python
 
-    from __future__ import absolute_import
-
     import time
 
     from proj.tasks import MyLongRunningTask
@@ -83,8 +79,6 @@ have it block until the task is finished.
    database backend.  Therefore, this class will only work with the
    database backends.
 """
-from __future__ import absolute_import, unicode_literals
-
 from celery import Task
 from celery.result import AsyncResult
 

celery/contrib/migrate.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Message migration tools (Broker <-> Broker)."""
-from __future__ import absolute_import, print_function, unicode_literals
-
 import socket
 
 from functools import partial

celery/contrib/rdb.py

@@ -41,8 +41,6 @@ Environment Variables
     The debugger will try to find an available port starting from the
     base port.  The selected port will be logged by the worker.
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 import errno
 import os
 import socket

celery/contrib/sphinx.py

@@ -28,8 +28,6 @@ using `:task:proj.tasks.add` syntax.
 
 Use ``.. autotask::`` to manually document a task.
 """
-from __future__ import absolute_import, unicode_literals
-
 from inspect import formatargspec, getfullargspec
 
 from sphinx.domains.python import PyModulelevel

celery/events/__init__.py

@@ -5,8 +5,6 @@ Events is a stream of messages sent for certain actions occurring
 in the worker (and clients if :setting:`task_send_sent_event`
 is enabled), used for monitoring purposes.
 """
-from __future__ import absolute_import, unicode_literals
-
 import os
 import time
 import threading

celery/events/cursesmon.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Graphical monitor of Celery events using curses."""
-from __future__ import absolute_import, print_function, unicode_literals
-
 import curses
 import sys
 import threading

celery/events/dumper.py

@@ -4,8 +4,6 @@
 This is a simple program that dumps events to the console
 as they happen. Think of it like a `tcpdump` for Celery events.
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 import sys
 
 from datetime import datetime

celery/events/snapshot.py

@@ -7,8 +7,6 @@ state of a cluster at regular intervals.  There is a full
 implementation of this writing the snapshots to a database
 in :mod:`djcelery.snapshots` in the `django-celery` distribution.
 """
-from __future__ import absolute_import, print_function, unicode_literals
-
 from kombu.utils.limits import TokenBucket
 
 from celery import platforms

celery/events/state.py

@@ -13,8 +13,6 @@ Snapshots (:mod:`celery.events.snapshot`) can be used to
 take "pictures" of this state at regular intervals
 to e.g. store that in a database.
 """
-from __future__ import absolute_import, unicode_literals
-
 import bisect
 import sys
 import threading

celery/exceptions.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """This module contains all exceptions used by the Celery API."""
-from __future__ import absolute_import, unicode_literals
-
 import numbers
 
 from billiard.exceptions import (  # noqa

celery/five.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Python 2/3 compatibility utilities."""
-from __future__ import absolute_import, unicode_literals
-
 import operator
 import sys
 

celery/fixups/django.py

@@ -1,6 +1,4 @@
 """Django-specific customization."""
-from __future__ import absolute_import, unicode_literals
-
 import os
 import sys
 import warnings

celery/loaders/__init__.py

@@ -4,8 +4,6 @@
 Loaders define how configuration is read, what happens
 when workers start, when tasks are executed and so on.
 """
-from __future__ import absolute_import, unicode_literals
-
 from celery.utils.imports import symbol_by_name, import_from_cwd
 
 __all__ = ['get_loader_cls']

celery/loaders/app.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """The default loader used with custom app instances."""
-from __future__ import absolute_import, unicode_literals
-
 from .base import BaseLoader
 
 __all__ = ['AppLoader']

celery/loaders/base.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Loader base class."""
-from __future__ import absolute_import, unicode_literals
-
 import imp as _imp
 import importlib
 import os

celery/loaders/default.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """The default loader used when no custom app has been initialized."""
-from __future__ import absolute_import, unicode_literals
-
 import os
 import warnings
 

celery/local.py

@@ -6,8 +6,6 @@ soon as possible, and that shall not load any third party modules.
 
 Parts of this module is Copyright by Werkzeug Team.
 """
-from __future__ import absolute_import, unicode_literals
-
 import importlib
 
 __all__ = ['Proxy', 'PromiseProxy', 'try_import', 'maybe_evaluate']

celery/platforms.py

@@ -1,8 +1,6 @@
 # -*- coding: utf-8 -*-
 """Utilities dealing with platform specifics: signals, daemonization,
 users, groups, and so on."""
-from __future__ import absolute_import, print_function, unicode_literals
-
 import atexit
 import errno
 import math
@@ -136,7 +134,7 @@ class Pidfile:
         """Acquire lock."""
         try:
             self.write_pid()
-        except FileExistsError:
+        except FileExistsError as exc:
             raise LockFailed(str(exc)).with_traceback(sys.exc_info()[2])
         return self
     __enter__ = acquire

celery/result.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Task results/state and results for groups of tasks."""
-from __future__ import absolute_import, unicode_literals
-
 import time
 
 from collections import OrderedDict, deque

celery/schedules.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Schedules define the intervals at which periodic tasks run."""
-from __future__ import absolute_import, unicode_literals
-
 import numbers
 import re
 

celery/security/__init__.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Message Signing Serializer."""
-from __future__ import absolute_import, unicode_literals
-
 from kombu.serialization import (
     registry, disable_insecure_serializers as _disable_insecure_serializers,
 )

celery/security/certificate.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """X.509 certificates."""
-from __future__ import absolute_import, unicode_literals
-
 import glob
 import os
 

celery/security/key.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Private keys for the security serializer."""
-from __future__ import absolute_import, unicode_literals
-
 from kombu.utils.encoding import ensure_bytes
 
 from .utils import crypto, reraise_errors

celery/security/serialization.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Secure serializer."""
-from __future__ import absolute_import, unicode_literals
-
 from kombu.serialization import registry, dumps, loads
 from kombu.utils.encoding import bytes_to_str, str_to_bytes, ensure_bytes
 

celery/security/utils.py

@@ -1,7 +1,5 @@
 # -*- coding: utf-8 -*-
 """Utilities used by the message signing serializer."""
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from contextlib import contextmanager

celery/signals.py

@@ -9,8 +9,6 @@ functions are called whenever a signal is called.
 
 See :ref:`signals` for more information.
 """
-from __future__ import absolute_import, unicode_literals
-
 from .utils.dispatch import Signal
 
 __all__ = [

celery/states.py

@@ -52,7 +52,6 @@ Misc.
 -----
 
 """
-from __future__ import absolute_import, unicode_literals
 
 __all__ = [
     'PENDING', 'RECEIVED', 'STARTED', 'SUCCESS', 'FAILURE',

celery/task/__init__.py

@@ -6,8 +6,6 @@ import from the main 'celery' module instead.
 If you're looking for the decorator implementation then that's in
 ``celery.app.base.Celery.task``.
 """
-from __future__ import absolute_import, unicode_literals
-
 from celery._state import current_app, current_task as current
 from celery.five import LazyModule, recreate_module
 from celery.local import Proxy

celery/task/base.py

@@ -6,8 +6,6 @@ The task implementation has been moved to :mod:`celery.app.task`.
 This contains the backward compatible Task class used in the old API,
 and shouldn't be used in new applications.
 """
-from __future__ import absolute_import, unicode_literals
-
 from kombu import Exchange
 
 from celery import current_app

celery/tests/__init__.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import logging
 import os
 import sys

celery/tests/app/test_amqp.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from datetime import datetime, timedelta
 
 from kombu import Exchange, Queue

celery/tests/app/test_annotations.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from celery.app.annotations import MapAnnotation, prepare
 from celery.utils.imports import qualname
 

celery/tests/app/test_app.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import gc
 import os
 import itertools

celery/tests/app/test_beat.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import errno
 
 from datetime import datetime, timedelta

celery/tests/app/test_builtins.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from celery import group, chord
 from celery.app import builtins
 from celery.utils.functional import pass1

celery/tests/app/test_celery.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from celery.tests.case import AppCase
 
 import celery

celery/tests/app/test_control.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from kombu.pidbox import Mailbox
 from vine.utils import wraps
 

celery/tests/app/test_defaults.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import sys
 
 from importlib import import_module

celery/tests/app/test_exceptions.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import pickle
 
 from datetime import datetime

celery/tests/app/test_loaders.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import os
 import sys
 import warnings

celery/tests/app/test_log.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 import sys
 import logging
 

celery/tests/app/test_registry.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from celery.app.registry import _unpickle_task, _unpickle_task_v2
 from celery.tests.case import AppCase, depends_on_current_app
 

celery/tests/app/test_routes.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, unicode_literals
-
 from kombu import Exchange, Queue
 from kombu.utils.functional import maybe_evaluate