isort.

celery/backends/dynamodb.py

@@ -10,6 +10,7 @@
 from celery.exceptions import ImproperlyConfigured
 from celery.five import string
 from celery.utils.log import get_logger
+
 from .base import KeyValueStoreBackend
 
 try:

celery/backends/redis.py

@@ -19,6 +19,7 @@
 from celery.utils.functional import dictfilter
 from celery.utils.log import get_logger
 from celery.utils.time import humanize_seconds
+
 from .asynchronous import AsyncBackendMixin, BaseResultConsumer
 from .base import BaseKeyValueStoreBackend
 

celery/concurrency/thread.py

@@ -3,8 +3,8 @@
 from __future__ import absolute_import, unicode_literals
 
 import sys
+from concurrent.futures import ThreadPoolExecutor, wait
 
-from concurrent.futures import wait, ThreadPoolExecutor
 from .base import BasePool, apply_target
 
 __all__ = ('TaskPool',)

celery/utils/__init__.py

@@ -9,8 +9,7 @@
 from kombu.utils.objects import cached_property
 from kombu.utils.uuid import uuid
 
-from .functional import chunks, noop
-from .functional import memoize
+from .functional import chunks, memoize, noop
 from .imports import gen_task_name, import_from_cwd, instantiate
 from .imports import qualname as get_full_cls_name
 from .imports import symbol_by_name as get_cls_by_name

celery/utils/log.py

@@ -16,6 +16,7 @@
 from kombu.utils.encoding import safe_str
 
 from celery.five import string_t, text_t
+
 from .term import colored
 
 __all__ = (

t/integration/test_canvas.py

@@ -8,8 +8,9 @@
 
 from celery import chain, chord, group, signature
 from celery.backends.base import BaseKeyValueStoreBackend
-from celery.exceptions import TimeoutError, ChordError
+from celery.exceptions import ChordError, TimeoutError
 from celery.result import AsyncResult, GroupResult, ResultSet
+
 from .conftest import get_active_redis_channels, get_redis_connection
 from .tasks import (ExpectedException, add, add_chord_to_chord, add_replaced,
                     add_to_all, add_to_all_to_chord, build_chain_inside_task,

t/integration/test_tasks.py

@@ -5,7 +5,8 @@
 from celery import group
 
 from .conftest import get_active_redis_channels
-from .tasks import add, add_ignore_result, print_unicode, retry_once, retry_once_priority, sleeping
+from .tasks import (add, add_ignore_result, print_unicode, retry_once,
+                    retry_once_priority, sleeping)
 
 
 class test_tasks:

t/unit/concurrency/test_thread.py

@@ -1,6 +1,7 @@
 from __future__ import absolute_import, unicode_literals
 
 import operator
+
 import pytest
 
 from celery.utils.functional import noop