Cosmetics

celery/__init__.py

@@ -7,11 +7,9 @@
 # :license:   BSD (3 Clause), see LICENSE for more details.
 
 from __future__ import absolute_import, print_function, unicode_literals
-
 import os
 import re
 import sys
-
 from collections import namedtuple
 
 SERIES = '0today8'

celery/__main__.py

@@ -1,8 +1,6 @@
 """Entry-point for the :program:`celery` umbrella command."""
 from __future__ import absolute_import, print_function, unicode_literals
-
 import sys
-
 from . import maybe_patch_concurrency
 
 __all__ = ['main']

celery/_state.py

@@ -7,12 +7,10 @@ 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
 import weakref
-
 from celery.local import Proxy
 from celery.utils.threads import LocalStack
 

celery/app/__init__.py

@@ -1,9 +1,7 @@
 # -*- coding: utf-8 -*-
 """Celery Application."""
 from __future__ import absolute_import, print_function, unicode_literals
-
 import os
-
 from celery.local import Proxy
 from celery import _state
 from celery._state import (
@@ -11,7 +9,6 @@ from celery._state import (
     get_current_task as current_task,
     connect_on_app_finalize, set_default_app, _get_active_apps, _task_stack,
 )
-
 from .base import Celery, AppPickler
 
 __all__ = [

celery/app/annotations.py

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

celery/app/backends.py

@@ -1,10 +1,8 @@
 # -*- coding: utf-8 -*-
 """Backend selection."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
 import types
-
 from celery.exceptions import ImproperlyConfigured
 from celery._state import current_app
 from celery.five import reraise

celery/app/builtins.py

@@ -4,12 +4,10 @@
 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
 
 __all__ = []
-
 logger = get_logger(__name__)
 
 

celery/app/control.py

@@ -5,15 +5,11 @@ 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
-
 from kombu.pidbox import Mailbox
 from kombu.utils.functional import lazy
 from kombu.utils.objects import cached_property
-
 from celery.exceptions import DuplicateNodenameWarning
 from celery.utils.text import pluralize
 

celery/app/defaults.py

@@ -1,12 +1,9 @@
 # -*- coding: utf-8 -*-
 """Configuration introspection and defaults."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
-
 from collections import deque, namedtuple
 from datetime import timedelta
-
 from celery.five import items, keys, python_2_unicode_compatible
 from celery.utils.functional import memoize
 from celery.utils.serialization import strtobool

celery/app/registry.py

@@ -1,11 +1,8 @@
 # -*- coding: utf-8 -*-
 """Registry of available tasks."""
 from __future__ import absolute_import, unicode_literals
-
 import inspect
-
 from importlib import import_module
-
 from celery._state import get_current_app
 from celery.exceptions import NotRegistered
 from celery.five import items

celery/app/routes.py

@@ -4,14 +4,10 @@
 Contains utilities for working with task routers, (:setting:`task_routes`).
 """
 from __future__ import absolute_import, unicode_literals
-
 import re
 import string
-
 from collections import Mapping, OrderedDict
-
 from kombu import Queue
-
 from celery.exceptions import QueueNotFound
 from celery.five import items, string_t
 from celery.utils.collections import lpmerge

celery/apps/beat.py

@@ -8,13 +8,10 @@ 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
-
 from datetime import datetime
-
 from celery import VERSION_BANNER, platforms, beat
 from celery.five import text_t
 from celery.utils.imports import qualname

celery/backends/__init__.py

@@ -1,6 +1,5 @@
 """Result Backends."""
 from __future__ import absolute_import, unicode_literals
-
 from celery.app import backends as _backends
 from celery.utils import deprecated
 

celery/backends/cache.py

@@ -1,15 +1,11 @@
 # -*- coding: utf-8 -*-
 """Memcached and in-memory cache result backend."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
-
 from kombu.utils.encoding import bytes_to_str, ensure_bytes
 from kombu.utils.objects import cached_property
-
 from celery.exceptions import ImproperlyConfigured
 from celery.utils.functional import LRUCache
-
 from .base import KeyValueStoreBackend
 
 __all__ = ['CacheBackend']

celery/backends/cassandra.py

@@ -1,8 +1,11 @@
 # -* coding: utf-8 -*-
 """Apache Cassandra result store backend using the DataStax driver."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
+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
     import cassandra.auth
@@ -10,10 +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']
 

celery/backends/consul.py

@@ -5,13 +5,10 @@
     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
 from celery.backends.base import KeyValueStoreBackend, PY3
 from celery.utils.log import get_logger
-
 try:
     import consul
 except ImportError:

celery/backends/couchbase.py

@@ -1,9 +1,11 @@
 # -*- coding: utf-8 -*-
 """Couchbase result store backend."""
 from __future__ import absolute_import, unicode_literals
-
 import logging
-
+from kombu.utils.encoding import str_t
+from kombu.utils.url import _parse_url
+from celery.exceptions import ImproperlyConfigured
+from .base import KeyValueStoreBackend
 try:
     from couchbase import Couchbase
     from couchbase.connection import Connection
@@ -11,13 +13,6 @@ try:
 except ImportError:
     Couchbase = Connection = NotFoundError = None   # noqa
 
-from kombu.utils.encoding import str_t
-from kombu.utils.url import _parse_url
-
-from celery.exceptions import ImproperlyConfigured
-
-from .base import KeyValueStoreBackend
-
 __all__ = ['CouchbaseBackend']
 
 

celery/backends/couchdb.py

@@ -1,13 +1,9 @@
 # -*- 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
-
 from .base import KeyValueStoreBackend
-
 try:
     import pycouchdb
 except ImportError:

celery/backends/database/models.py

@@ -1,15 +1,11 @@
 # -*- 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
+from datetime import datetime
 from sqlalchemy.types import PickleType
-
 from celery import states
 from celery.five import python_2_unicode_compatible
-
 from .session import ResultModelBase
 
 __all__ = ['Task', 'TaskSet']

celery/backends/database/session.py

@@ -1,12 +1,10 @@
 # -*- 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
 from sqlalchemy.pool import NullPool
-
 from kombu.utils.compat import register_after_fork
 
 ResultModelBase = declarative_base()

celery/backends/elasticsearch.py

@@ -1,15 +1,10 @@
 # -* 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
-
 from celery.exceptions import ImproperlyConfigured
-
 from .base import KeyValueStoreBackend
-
 try:
     import elasticsearch
 except ImportError:

celery/backends/filesystem.py

@@ -1,17 +1,13 @@
 # -*- coding: utf-8 -*-
 """File-system result store backend."""
 from __future__ import absolute_import, unicode_literals
-
+import os
+import locale
 from kombu.utils.encoding import ensure_bytes
-
 from celery import uuid
 from celery.exceptions import ImproperlyConfigured
 from celery.backends.base import KeyValueStoreBackend
 
-import os
-import locale
-default_encoding = locale.getpreferredencoding(False)
-
 # Python 2 does not have FileNotFoundError and IsADirectoryError
 try:
     FileNotFoundError
@@ -19,6 +15,8 @@ except NameError:
     FileNotFoundError = IOError
     IsADirectoryError = IOError
 
+default_encoding = locale.getpreferredencoding(False)
+
 E_PATH_INVALID = """\
 The configured path for the file-system backend does not
 work correctly, please make sure that it exists and has

celery/backends/mongodb.py

@@ -1,17 +1,13 @@
 # -*- coding: utf-8 -*-
 """MongoDB result store backend."""
 from __future__ import absolute_import, unicode_literals
-
 from datetime import datetime, timedelta
-
 from kombu.utils.objects import cached_property
 from kombu.utils.url import maybe_sanitize_url
 from kombu.exceptions import EncodeError
-
 from celery import states
 from celery.exceptions import ImproperlyConfigured
 from celery.five import string_t, items
-
 from .base import BaseBackend
 
 try:

celery/backends/riak.py

@@ -1,9 +1,10 @@
 # -*- coding: utf-8 -*-
 """Riak result store backend."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
-
+from kombu.utils.url import _parse_url
+from celery.exceptions import ImproperlyConfigured
+from .base import KeyValueStoreBackend
 try:
     import riak
     from riak import RiakClient
@@ -11,12 +12,6 @@ try:
 except ImportError:  # pragma: no cover
     riak = RiakClient = last_written_resolver = None  # noqa
 
-from kombu.utils.url import _parse_url
-
-from celery.exceptions import ImproperlyConfigured
-
-from .base import KeyValueStoreBackend
-
 __all__ = ['RiakBackend']
 
 E_BUCKET_NAME = """\

celery/bin/__init__.py

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

celery/bin/beat.py

@@ -65,11 +65,8 @@
     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
-
 from celery.bin.base import Command, daemon_options
 
 __all__ = ['beat']

celery/bin/celery.py

@@ -190,7 +190,6 @@ in any command that also has a `--detach` option.
 
     Use :pypi:`gevent` monkey patches.
 
-
 ``celery result``
 -----------------
 

celery/bin/celeryd_detach.py

@@ -6,22 +6,17 @@ 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 argparse
 import celery
 import os
 import sys
-
 from celery.platforms import EX_FAILURE, detached
 from celery.utils.log import get_logger
 from celery.utils.nodenames import default_nodename, node_format
-
 from celery.bin.base import daemon_options
 
 __all__ = ['detached_celeryd', 'detach']
-
 logger = get_logger(__name__)
-
 C_FAKEFORK = os.environ.get('C_FAKEFORK')
 
 

celery/bin/events.py

@@ -66,11 +66,8 @@
     Executable to use for the detached process.
 """
 from __future__ import absolute_import, unicode_literals
-
 import sys
-
 from functools import partial
-
 from celery.platforms import detached, set_process_title, strargv
 from celery.bin.base import Command, daemon_options
 

celery/bin/graph.py

@@ -4,12 +4,9 @@
 .. program:: celery graph
 """
 from __future__ import absolute_import, unicode_literals
-
 from operator import itemgetter
-
 from celery.five import items, python_2_unicode_compatible
 from celery.utils.graph import DependencyGraph, GraphFormatter
-
 from .base import Command
 
 __all__ = ['graph']

celery/bin/logtool.py

@@ -5,12 +5,9 @@
 """
 
 from __future__ import absolute_import, unicode_literals
-
 import re
-
 from collections import Counter
 from fileinput import FileInput
-
 from .base import Command
 
 __all__ = ['logtool']

celery/bin/multi.py

@@ -94,15 +94,11 @@ Examples
     celery worker -n xuzzy@myhost -c 3
 """
 from __future__ import absolute_import, print_function, unicode_literals
-
 import os
 import signal
 import sys
-
 from functools import wraps
-
 from kombu.utils.objects import cached_property
-
 from celery import VERSION_BANNER
 from celery.apps.multi import Cluster, MultiParser, NamespacedOptionParser
 from celery.platforms import EX_FAILURE, EX_OK, signals

celery/bin/worker.py

@@ -176,9 +176,7 @@ 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 celery import concurrency
 from celery.bin.base import Command, daemon_options
 from celery.bin.celeryd_detach import detached_celeryd

celery/concurrency/eventlet.py

@@ -1,9 +1,7 @@
 # -*- coding: utf-8 -*-
 """Eventlet execution pool."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
-
 from kombu.five import monotonic
 
 __all__ = ['TaskPool']

celery/concurrency/gevent.py

@@ -1,17 +1,14 @@
 # -*- coding: utf-8 -*-
 """Gevent execution pool."""
 from __future__ import absolute_import, unicode_literals
-
+from kombu.async import timer as _timer
+from kombu.five import monotonic
+from . import base
 try:
     from gevent import Timeout
 except ImportError:  # pragma: no cover
     Timeout = None  # noqa
 
-from kombu.async import timer as _timer
-from kombu.five import monotonic
-
-from . import base
-
 __all__ = ['TaskPool']
 
 # pylint: disable=redefined-outer-name

celery/concurrency/solo.py

@@ -1,9 +1,7 @@
 # -*- coding: utf-8 -*-
 """Single-threaded execution pool."""
 from __future__ import absolute_import, unicode_literals
-
 import os
-
 from .base import BasePool, apply_target
 
 __all__ = ['TaskPool']

celery/contrib/abortable.py

@@ -84,7 +84,6 @@ have it block until the task is finished.
    database backends.
 """
 from __future__ import absolute_import, unicode_literals
-
 from celery import Task
 from celery.result import AsyncResult
 

celery/contrib/pytest.py

@@ -1,11 +1,8 @@
 """Fixtures and testing utilities for :pypi:`py.test <pytest>`."""
 from __future__ import absolute_import, unicode_literals
-
 import os
 import pytest
-
 from contextlib import contextmanager
-
 from .testing import worker
 from .testing.app import TestApp, setup_default_app
 

celery/contrib/rdb.py

@@ -42,16 +42,12 @@ Environment Variables
     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
 import sys
-
 from pdb import Pdb
-
 from billiard.process import current_process
-
 from celery.five import range
 
 __all__ = [

celery/contrib/sphinx.py

@@ -29,12 +29,9 @@ using `:task:proj.tasks.add` syntax.
 Use ``.. autotask::`` to manually document a task.
 """
 from __future__ import absolute_import, unicode_literals
-
 from inspect import formatargspec
-
 from sphinx.domains.python import PyModulelevel
 from sphinx.ext.autodoc import FunctionDocumenter
-
 from celery.app.task import BaseTask
 from celery.five import getfullargspec
 

celery/contrib/testing/app.py

@@ -1,13 +1,9 @@
 """Create Celery app instances used for testing."""
 from __future__ import absolute_import, unicode_literals
-
 import weakref
-
 from contextlib import contextmanager
 from copy import deepcopy
-
 from kombu.utils.imports import symbol_by_name
-
 from celery import Celery
 from celery import _state
 

celery/contrib/testing/mocks.py

@@ -1,10 +1,7 @@
 """Useful mocks for unit testing."""
 from __future__ import absolute_import, unicode_literals
-
 import numbers
-
 from datetime import datetime, timedelta
-
 try:
     from case import Mock
 except ImportError:

celery/contrib/testing/tasks.py

@@ -1,6 +1,5 @@
 """Helper tasks for integration tests."""
 from __future__ import absolute_import, unicode_literals
-
 from celery import shared_task
 
 

celery/contrib/testing/worker.py

@@ -1,11 +1,8 @@
 """Embedded workers for integration tests."""
 from __future__ import absolute_import, unicode_literals
-
 import os
 import threading
-
 from contextlib import contextmanager
-
 from celery import worker
 from celery.result import allow_join_result, _set_task_join_will_block
 from celery.utils.dispatch import Signal

celery/events/__init__.py

@@ -6,7 +6,6 @@ in the worker (and clients if :setting:`task_send_sent_event`
 is enabled), used for monitoring purposes.
 """
 from __future__ import absolute_import, unicode_literals
-
 from .dispatcher import EventDispatcher
 from .event import Event, event_exchange, get_exchange, group_from
 from .receiver import EventReceiver

celery/events/dumper.py

@@ -5,11 +5,8 @@ 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
-
 from celery.app import app_or_default
 from celery.utils.functional import LRUCache
 from celery.utils.time import humanize_seconds

celery/events/snapshot.py

@@ -8,9 +8,7 @@ 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
 from celery.app import app_or_default
 from celery.utils.timer2 import Timer

celery/exceptions.py

@@ -48,12 +48,9 @@ Error Hierarchy
         - :exc:`~celery.exceptions.WorkerShutdown`
 """
 from __future__ import absolute_import, unicode_literals
-
 import numbers
-
 from .five import python_2_unicode_compatible, string_t
-
-from billiard.exceptions import (  # noqa
+from billiard.exceptions import (
     SoftTimeLimitExceeded, TimeLimitExceeded, WorkerLostError, Terminated,
 )
 from kombu.exceptions import OperationalError

celery/five.py

@@ -1,8 +1,6 @@
 # -*- coding: utf-8 -*-
 """Python 2/3 compatibility utilities."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
 import vine.five
-
 sys.modules[__name__] = vine.five

celery/loaders/__init__.py

@@ -5,7 +5,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,6 @@
 # -*- 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/default.py

@@ -1,14 +1,11 @@
 # -*- 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
-
 from celery.exceptions import NotConfigured
 from celery.utils.collections import DictAttribute
 from celery.utils.serialization import strtobool
-
 from .base import BaseLoader
 
 __all__ = ['Loader', 'DEFAULT_CONFIG_MODULE']

celery/local.py

@@ -7,14 +7,11 @@ 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 operator
 import sys
-
 from functools import reduce
 from importlib import import_module
 from types import ModuleType
-
 from .five import bytes_if_py2, items, string, string_t
 
 __all__ = ['Proxy', 'PromiseProxy', 'try_import', 'maybe_evaluate']

celery/security/__init__.py

@@ -1,13 +1,10 @@
 # -*- 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,
 )
-
 from celery.exceptions import ImproperlyConfigured
-
 from .serialization import register_auth
 
 SSL_NOT_INSTALLED = """\

celery/security/certificate.py

@@ -1,15 +1,11 @@
 # -*- coding: utf-8 -*-
 """X.509 certificates."""
 from __future__ import absolute_import, unicode_literals
-
 import glob
 import os
-
 from kombu.utils.encoding import bytes_to_str
-
 from celery.exceptions import SecurityError
 from celery.five import values
-
 from .utils import crypto, reraise_errors
 
 __all__ = ['Certificate', 'CertStore', 'FSCertStore']

celery/security/key.py

@@ -1,9 +1,7 @@
 # -*- 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
 
 __all__ = ['PrivateKey']

celery/security/utils.py

@@ -1,14 +1,10 @@
 # -*- coding: utf-8 -*-
 """Utilities used by the message signing serializer."""
 from __future__ import absolute_import, unicode_literals
-
 import sys
-
 from contextlib import contextmanager
-
 from celery.exceptions import SecurityError
 from celery.five import reraise
-
 try:
     from OpenSSL import crypto
 except ImportError:  # pragma: no cover

celery/signals.py

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

celery/task/__init__.py

@@ -7,7 +7,6 @@ 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.local import LazyModule, Proxy, recreate_module
 

celery/task/base.py

@@ -7,9 +7,7 @@ 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
 from celery.app.task import Context, Task as BaseTask, _reprtask
 from celery.five import python_2_unicode_compatible, with_metaclass

celery/utils/__init__.py

@@ -5,11 +5,8 @@ Don't import from here directly anymore, as these are only
 here for backwards compatibility.
 """
 from __future__ import absolute_import, print_function, unicode_literals
-
 import sys
-
 from .functional import memoize  # noqa
-
 from .nodenames import worker_direct, nodename, nodesplit
 
 __all__ = ['worker_direct', 'gen_task_name', 'nodename', 'nodesplit',

celery/utils/abstract.py

@@ -1,10 +1,8 @@
 # -*- coding: utf-8 -*-
 """Abstract classes."""
 from __future__ import absolute_import, unicode_literals
-
 from abc import ABCMeta, abstractmethod, abstractproperty
 from collections import Callable
-
 from celery.five import with_metaclass
 
 __all__ = ['CallableTask', 'CallableSignature']

celery/utils/deprecated.py

@@ -1,11 +1,8 @@
 # -*- coding: utf-8 -*-
 """Deprecation utilities."""
 from __future__ import absolute_import, print_function, unicode_literals
-
 import warnings
-
 from vine.utils import wraps
-
 from celery.exceptions import CPendingDeprecationWarning, CDeprecationWarning
 
 __all__ = ['Callable', 'Property', 'warn']

celery/utils/dispatch/__init__.py

@@ -1,7 +1,6 @@
 # -*- coding: utf-8 -*-
 """Observer pattern."""
 from __future__ import absolute_import, unicode_literals
-
 from .signal import Signal
 
 __all__ = ['Signal']

celery/utils/dispatch/saferef.py

@@ -5,11 +5,9 @@ Provides a way to safely weakref any function, including bound methods (which
 aren't handled by the core weakref module).
 """
 from __future__ import absolute_import, unicode_literals
-
 import sys
 import traceback
 import weakref
-
 from celery.five import python_2_unicode_compatible
 
 __all__ = ['safe_ref']

celery/utils/dispatch/signal.py

@@ -1,13 +1,10 @@
 # -*- coding: utf-8 -*-
 """Implementation of the Observer pattern."""
 from __future__ import absolute_import, unicode_literals
-
 import weakref
-
 from celery.five import python_2_unicode_compatible, range, text_t
 from celery.local import PromiseProxy, Proxy
 from celery.utils.log import get_logger
-
 from . import saferef
 
 __all__ = ['Signal']

celery/utils/encoding.py

@@ -1,7 +1,6 @@
 # -*- coding: utf-8 -*-
 """**DEPRECATED**: This module has moved to :mod:`kombu.utils.encoding`."""
 from __future__ import absolute_import, unicode_literals
-
 from kombu.utils.encoding import (  # noqa
     default_encode, default_encoding, bytes_t, bytes_to_str, str_t,
     str_to_bytes, ensure_bytes, from_utf8, safe_str, safe_repr,

celery/utils/graph.py

@@ -1,12 +1,9 @@
 # -*- coding: utf-8 -*-
 """Dependency graph implementation."""
 from __future__ import absolute_import, print_function, unicode_literals
-
 from collections import Counter
 from textwrap import dedent
-
 from kombu.utils.encoding import safe_str, bytes_to_str
-
 from celery.five import items, python_2_unicode_compatible
 
 __all__ = ['DOT', 'CycleError', 'DependencyGraph', 'GraphFormatter']

celery/utils/imports.py

@@ -1,17 +1,13 @@
 # -*- coding: utf-8 -*-
 """Utilities related to importing modules and symbols by name."""
 from __future__ import absolute_import, unicode_literals
-
 import imp as _imp
 import importlib
 import os
 import sys
 import warnings
-
 from contextlib import contextmanager
-
 from kombu.utils.imports import symbol_by_name
-
 from celery.five import reload
 
 #: Billiard sets this when execv is enabled.

celery/utils/iso8601.py

@@ -33,9 +33,7 @@ TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 """
 from __future__ import absolute_import, unicode_literals
-
 import re
-
 from datetime import datetime
 from pytz import FixedOffset
 

celery/utils/nodenames.py

@@ -1,14 +1,10 @@
 # -*- coding: utf-8 -*-
 """Worker name utilities."""
 from __future__ import absolute_import, unicode_literals
-
 import os
 import socket
-
 from functools import partial
-
 from kombu.entity import Exchange, Queue
-
 from .functional import memoize
 from .text import simple_format
 

celery/utils/static/__init__.py

@@ -1,6 +1,5 @@
 """Static files."""
 from __future__ import absolute_import, unicode_literals
-
 import os
 
 

celery/utils/sysinfo.py

@@ -1,11 +1,8 @@
 # -*- coding: utf-8 -*-
 """System information utilities."""
 from __future__ import absolute_import, unicode_literals
-
 import os
-
 from math import ceil
-
 from kombu.utils.objects import cached_property
 
 __all__ = ['load_average', 'df']

celery/utils/term.py

@@ -1,16 +1,12 @@
 # -*- coding: utf-8 -*-
 """Terminals and colors."""
 from __future__ import absolute_import, unicode_literals
-
 import base64
 import codecs
 import os
 import sys
-
 import platform
-
 from functools import reduce
-
 from celery.five import python_2_unicode_compatible, string
 from celery.platforms import isatty
 

celery/utils/text.py

@@ -1,15 +1,11 @@
 # -*- coding: utf-8 -*-
 """Text formatting utilities."""
 from __future__ import absolute_import, unicode_literals
-
 import re
-
 from collections import Callable
 from functools import partial
 from textwrap import fill
-
 from pprint import pformat
-
 from celery.five import string_t
 
 __all__ = [

celery/worker/__init__.py

@@ -1,6 +1,5 @@
 """Worker implementation."""
 from __future__ import absolute_import, unicode_literals
-
 from .worker import WorkController
 
 __all__ = ['WorkController']

celery/worker/consumer/__init__.py

@@ -1,8 +1,6 @@
 """Worker consumer."""
 from __future__ import absolute_import, unicode_literals
-
 from .consumer import Consumer
-
 from .agent import Agent
 from .connection import Connection
 from .control import Control

celery/worker/consumer/agent.py

@@ -1,8 +1,6 @@
 """Celery + :pypi:`cell` integration."""
 from __future__ import absolute_import, unicode_literals
-
 from celery import bootsteps
-
 from .connection import Connection
 
 __all__ = ['Agent']

celery/worker/consumer/connection.py

@@ -1,8 +1,6 @@
 """Consumer Broker Connection Bootstep."""
 from __future__ import absolute_import, unicode_literals
-
 from kombu.common import ignore_errors
-
 from celery import bootsteps
 from celery.utils.log import get_logger
 

celery/worker/consumer/control.py

@@ -5,12 +5,9 @@
 The actual commands are implemented in :mod:`celery.worker.control`.
 """
 from __future__ import absolute_import, unicode_literals
-
 from celery import bootsteps
 from celery.utils.log import get_logger
-
 from celery.worker import pidbox
-
 from .tasks import Tasks
 
 __all__ = ['Control']

celery/worker/consumer/events.py

@@ -3,11 +3,8 @@
 ``Events`` -> :class:`celery.events.EventDispatcher`.
 """
 from __future__ import absolute_import, unicode_literals
-
 from kombu.common import ignore_errors
-
 from celery import bootsteps
-
 from .connection import Connection
 
 __all__ = ['Events']

celery/worker/consumer/heart.py

@@ -1,10 +1,7 @@
 """Worker Event Heartbeat Bootstep."""
 from __future__ import absolute_import, unicode_literals
-
 from celery import bootsteps
-
 from celery.worker import heartbeat
-
 from .events import Events
 
 __all__ = ['Heart']

celery/worker/consumer/mingle.py

@@ -1,10 +1,8 @@
 """Worker <-> Worker Sync at startup (Bootstep)."""
 from __future__ import absolute_import, unicode_literals
-
 from celery import bootsteps
 from celery.five import items
 from celery.utils.log import get_logger
-
 from .events import Events
 
 __all__ = ['Mingle']

celery/worker/consumer/tasks.py

@@ -1,14 +1,11 @@
 """Worker Task Consumer Bootstep."""
 from __future__ import absolute_import, unicode_literals
-
 from kombu.common import QoS, ignore_errors
-
 from celery import bootsteps
 from celery.utils.log import get_logger
-
 from .mingle import Mingle
 
-__all__ = ('Tasks',)
+__all__ = ['Tasks']
 logger = get_logger(__name__)
 debug = logger.debug
 

celery/worker/heartbeat.py

@@ -5,10 +5,8 @@ This is the internal thread responsible for sending heartbeat events
 at regular intervals (may not be an actual thread).
 """
 from __future__ import absolute_import, unicode_literals
-
 from celery.signals import heartbeat_sent
 from celery.utils.sysinfo import load_average
-
 from .state import SOFTWARE_INFO, active_requests, all_total_count
 
 __all__ = ['Heart']

celery/worker/loops.py

@@ -1,13 +1,10 @@
 """The consumers highly-optimized inner loop."""
 from __future__ import absolute_import, unicode_literals
-
 import errno
 import socket
-
 from celery import bootsteps
 from celery.exceptions import WorkerShutdown, WorkerTerminate, WorkerLostError
 from celery.utils.log import get_logger
-
 from . import state
 
 __all__ = ['asynloop', 'synloop']

celery/worker/pidbox.py

@@ -1,16 +1,12 @@
 """Worker Pidbox (remote control)."""
 from __future__ import absolute_import, unicode_literals
-
 import socket
 import threading
-
 from kombu.common import ignore_errors
 from kombu.utils.encoding import safe_str
-
 from celery.utils.collections import AttributeDict
 from celery.utils.functional import pass1
 from celery.utils.log import get_logger
-
 from . import control
 
 __all__ = ['Pidbox', 'gPidbox']

examples/app/myapp.py

@@ -23,7 +23,6 @@ name using the fully qualified form::
 
 """
 from __future__ import absolute_import, unicode_literals
-
 from celery import Celery
 
 app = Celery(

examples/celery_http_gateway/tasks.py

@@ -1,5 +1,4 @@
 from __future__ import absolute_import, unicode_literals
-
 from celery import task
 
 

examples/django/demoapp/models.py

@@ -1,3 +1,4 @@
+from __future__ import absolute_import, unicode_literals
 from django.db import models  # noqa
 
 # Create your models here.

examples/django/demoapp/tasks.py

@@ -1,5 +1,5 @@
-from __future__ import absolute_import
-
+# Create your tasks here
+from __future__ import absolute_import, unicode_literals
 from celery import shared_task
 
 

examples/django/demoapp/views.py

@@ -1 +1,2 @@
+from __future__ import absolute_import, unicode_literals
 # Create your views here.

examples/django/proj/celery.py

@@ -1,7 +1,5 @@
 from __future__ import absolute_import, unicode_literals
-
 import os
-
 from celery import Celery
 
 # set the default Django settings module for the 'celery' program.
@@ -9,11 +7,13 @@ os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
 
 app = Celery('proj')
 
-# Using a string here means the worker doesn't have to serialize
-# the configuration object.
+# Using a string here means the worker don't have to serialize
+# the configuration object to child processes.
+# - namespace='CELERY' means all celery-related configuration keys
+#   should have a `CELERY_` prefix.
 app.config_from_object('django.conf:settings', namespace='CELERY')
 
-# load task modules from all registered Django app configs.
+# Load task modules from all registered Django app configs.
 app.autodiscover_tasks()
 
 

examples/django/proj/wsgi.py

@@ -14,7 +14,6 @@ framework.
 
 """
 from __future__ import absolute_import, unicode_literals
-
 import os
 
 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')

examples/eventlet/bulk_task_producer.py

@@ -1,5 +1,4 @@
 from __future__ import absolute_import, unicode_literals
-
 from eventlet import spawn_n, monkey_patch, Timeout
 from eventlet.queue import LightQueue
 from eventlet.event import Event

examples/eventlet/celeryconfig.py

@@ -1,5 +1,4 @@
 from __future__ import absolute_import, unicode_literals
-
 import os
 import sys
 sys.path.insert(0, os.getcwd())

examples/eventlet/tasks.py

@@ -1,7 +1,5 @@
 from __future__ import absolute_import, unicode_literals, print_function
-
 import requests
-
 from celery import task
 
 

examples/eventlet/webcrawler.py

@@ -19,21 +19,16 @@ We don't have to do compression manually, just set the tasks compression
 to "zlib", and the serializer to "pickle".
 
 """
-from __future__ import absolute_import, unicode_literals
-
+from __future__ import absolute_import, print_function, unicode_literals
 import re
-
-try:
-    from urllib.parse import urlsplit
-except ImportError:
-    from urlparse import urlsplit  # noqa
-
 import requests
-
 from celery import task, group
 from eventlet import Timeout
-
 from pybloom import BloomFilter
+try:
+    from urllib.parse import urlsplit
+except ImportError:
+    from urlparse import urlsplit  # noqa
 
 # http://daringfireball.net/2009/11/liberal_regex_for_matching_urls
 url_regex = re.compile(
@@ -67,4 +62,4 @@ def crawl(url, seen=None):
             seen.add(url)
 
     subtasks = group(crawl.s(url, seen) for url in wanted_urls)
-    subtasks()
+    subtasks.delay()

examples/gevent/celeryconfig.py

@@ -1,5 +1,4 @@
 from __future__ import absolute_import, unicode_literals
-
 import os
 import sys
 sys.path.insert(0, os.getcwd())

examples/gevent/tasks.py

@@ -1,7 +1,5 @@
-from __future__ import absolute_import, unicode_literals
-
+from __future__ import absolute_import, print_function, unicode_literals
 import requests
-
 from celery import task