|
55 | 55 | from redis.exceptions import (AskError, MovedError, RedisClusterException, |
56 | 56 | TryAgainError) |
57 | 57 |
|
58 | | -from kombu.transport import virtual |
59 | 58 | from kombu.exceptions import VersionMismatch |
60 | 59 | from kombu.log import get_logger |
| 60 | +from kombu.transport import virtual |
61 | 61 | from kombu.transport.virtual.base import Channel as VirtualBaseChannel |
62 | 62 | from kombu.utils import uuid |
| 63 | +from kombu.utils.compat import register_after_fork |
63 | 64 | from kombu.utils.encoding import bytes_to_str |
64 | 65 | from kombu.utils.eventio import ERR, READ |
65 | 66 | from kombu.utils.json import loads, dumps |
66 | 67 | from kombu.utils.objects import cached_property |
67 | | -from kombu.utils.compat import register_after_fork |
68 | 68 |
|
69 | | -from .redis import Channel as RedisChannel, _after_fork_cleanup_channel |
| 69 | +from ..utils.scheduling import cycle_by_name |
| 70 | +from .redis import Channel as RedisChannel |
70 | 71 | from .redis import GlobalKeyPrefixMixin as RedisGlobalKeyPrefixMixin |
71 | 72 | from .redis import MultiChannelPoller as RedisMultiChannelPoller |
72 | 73 | from .redis import MutexHeld |
73 | 74 | from .redis import QoS as RedisQoS |
74 | 75 | from .redis import Transport as RedisTransport |
75 | | -from ..utils.scheduling import cycle_by_name |
| 76 | +from .redis import _after_fork_cleanup_channel |
76 | 77 |
|
77 | 78 | try: |
78 | 79 | import redis |
|
0 commit comments