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 @@
 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,17 +1,14 @@
 # -*- 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 (
     get_current_app as current_app,
     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 @@
 :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 @@
 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 @@
 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,19 +1,18 @@
 # -* 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
     import cassandra.cluster
 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,23 +1,18 @@
 # -*- 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
     from couchbase.exceptions import NotFoundError
 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,24 +1,22 @@
 # -*- 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
 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,22 +1,17 @@
 # -*- 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
     from riak.resolver import last_written_resolver
 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']