mirror of https://github.com/celery/kombu.git
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
This commit is contained in:
parent
1ff07831af
commit
bb86af2407
|
@ -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):
|
||||
|
|
Loading…
Reference in New Issue