From 06fa39b4b8dd9193b05c56c354ff3f1283c9da5f Mon Sep 17 00:00:00 2001 From: QuantumGhost Date: Tue, 10 Feb 2026 18:17:08 +0800 Subject: [PATCH] chore(api): add some log to ensure that the patch actually works --- api/libs/broadcast_channel/redis/_subscription.py | 2 ++ api/libs/broadcast_channel/redis/sharded_channel.py | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/api/libs/broadcast_channel/redis/_subscription.py b/api/libs/broadcast_channel/redis/_subscription.py index 40027bc424..ec527a5e11 100644 --- a/api/libs/broadcast_channel/redis/_subscription.py +++ b/api/libs/broadcast_channel/redis/_subscription.py @@ -28,6 +28,7 @@ class RedisSubscriptionBase(Subscription): topic: str, ): # The _pubsub is None only if the subscription is closed. + _logger.info("Client type for redis connection: type=%s, topic=%s", type(client), topic) self._client = client self._pubsub: PubSub | None = pubsub self._topic = topic @@ -79,6 +80,7 @@ class RedisSubscriptionBase(Subscription): exc_info=True, ) break + _logger.info("Message is none for subscription: ", self._topic) if raw_message is None: continue diff --git a/api/libs/broadcast_channel/redis/sharded_channel.py b/api/libs/broadcast_channel/redis/sharded_channel.py index 290c077d11..5e4e61793c 100644 --- a/api/libs/broadcast_channel/redis/sharded_channel.py +++ b/api/libs/broadcast_channel/redis/sharded_channel.py @@ -1,5 +1,7 @@ from __future__ import annotations +import logging + from libs.broadcast_channel.channel import Producer, Subscriber, Subscription from redis import Redis, RedisCluster @@ -75,6 +77,8 @@ class _RedisShardedSubscription(RedisSubscriptionBase): # # Here we specify the `target_node` to mitigate this problem. node = self._client.get_node_from_key(self._topic) + logger = logging.getLogger(__name__) + logger.info("node retrieved from client: %s", node) return self._pubsub.get_sharded_message( # type: ignore[attr-defined] ignore_subscribe_messages=False, timeout=1,