From 535151945a950a7f4f04fff63a6402e0affe0dcf Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Tue, 24 Dec 2024 12:56:24 +0000 Subject: [PATCH] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- kombu/transport/rediscluster.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/kombu/transport/rediscluster.py b/kombu/transport/rediscluster.py index 23da4a29c..c01663b1e 100644 --- a/kombu/transport/rediscluster.py +++ b/kombu/transport/rediscluster.py @@ -55,24 +55,25 @@ from redis.exceptions import (AskError, MovedError, RedisClusterException, TryAgainError) -from kombu.transport import virtual from kombu.exceptions import VersionMismatch from kombu.log import get_logger +from kombu.transport import virtual from kombu.transport.virtual.base import Channel as VirtualBaseChannel from kombu.utils import uuid +from kombu.utils.compat import register_after_fork from kombu.utils.encoding import bytes_to_str from kombu.utils.eventio import ERR, READ from kombu.utils.json import loads from kombu.utils.objects import cached_property -from kombu.utils.compat import register_after_fork -from .redis import Channel as RedisChannel, _after_fork_cleanup_channel +from ..utils.scheduling import cycle_by_name +from .redis import Channel as RedisChannel from .redis import GlobalKeyPrefixMixin as RedisGlobalKeyPrefixMixin from .redis import MultiChannelPoller as RedisMultiChannelPoller from .redis import MutexHeld from .redis import QoS as RedisQoS from .redis import Transport as RedisTransport -from ..utils.scheduling import cycle_by_name +from .redis import _after_fork_cleanup_channel try: import redis