From cf829307991da3815e1f7b105e736d13dbc7a325 Mon Sep 17 00:00:00 2001 From: Omer Katz Date: Sun, 8 Dec 2019 16:50:00 +0200 Subject: [PATCH] isort. --- celery/backends/dynamodb.py | 1 + celery/backends/redis.py | 1 + celery/concurrency/thread.py | 2 +- celery/utils/__init__.py | 3 +-- celery/utils/log.py | 1 + t/integration/test_canvas.py | 3 ++- t/integration/test_tasks.py | 3 ++- t/unit/concurrency/test_thread.py | 1 + 8 files changed, 10 insertions(+), 5 deletions(-) diff --git a/celery/backends/dynamodb.py b/celery/backends/dynamodb.py index 8359000a5a2..3be4250ac61 100644 --- a/celery/backends/dynamodb.py +++ b/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: diff --git a/celery/backends/redis.py b/celery/backends/redis.py index 9a0ea28682e..a309b7a8aeb 100644 --- a/celery/backends/redis.py +++ b/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 diff --git a/celery/concurrency/thread.py b/celery/concurrency/thread.py index 4daacef72f5..1c6ba1aa9e7 100644 --- a/celery/concurrency/thread.py +++ b/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',) diff --git a/celery/utils/__init__.py b/celery/utils/__init__.py index 5c7a0c16958..4c321ec372a 100644 --- a/celery/utils/__init__.py +++ b/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 diff --git a/celery/utils/log.py b/celery/utils/log.py index 59e7311bde7..2b07a1fcdaa 100644 --- a/celery/utils/log.py +++ b/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__ = ( diff --git a/t/integration/test_canvas.py b/t/integration/test_canvas.py index bf97cae4159..032905fccb4 100644 --- a/t/integration/test_canvas.py +++ b/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, diff --git a/t/integration/test_tasks.py b/t/integration/test_tasks.py index 4cb7efff0d6..89ca9d41e4d 100644 --- a/t/integration/test_tasks.py +++ b/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: diff --git a/t/unit/concurrency/test_thread.py b/t/unit/concurrency/test_thread.py index de80e5dd265..fa94d98718a 100644 --- a/t/unit/concurrency/test_thread.py +++ b/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