diff --git a/t/unit/transport/test_rediscluster.py b/t/unit/transport/test_rediscluster.py index 7c102b1f..943fe7ad 100644 --- a/t/unit/transport/test_rediscluster.py +++ b/t/unit/transport/test_rediscluster.py @@ -5,23 +5,25 @@ import copy import socket from itertools import count from queue import Empty -from unittest.mock import Mock, patch, call +from unittest.mock import Mock, call, patch import pytest from redis.exceptions import MovedError -from kombu.utils import eventio - from kombu import Connection, Consumer, Exchange, Producer, Queue -from kombu.transport import rediscluster as redis, virtual +from kombu.transport import rediscluster as redis +from kombu.transport import virtual +from kombu.utils import eventio from kombu.utils.json import dumps from t.unit.transport.virtual.test_base import client pytest.importorskip('redis') -from t.unit.transport.test_redis import Client, _poll, test_GlobalKeyPrefixMixin import redis as _redis +from t.unit.transport.test_redis import (Client, _poll, + test_GlobalKeyPrefixMixin) + class ClusterNode: def __init__(self, host=None, port=None):