From b31d506c9f7b541e0b8022aafdb8d44e0478ea3c Mon Sep 17 00:00:00 2001 From: wyzula-jan Date: Thu, 25 Apr 2024 15:57:55 +0200 Subject: [PATCH] fix(redis_connector): unregister is not killing communication --- bec_lib/bec_lib/redis_connector.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/bec_lib/bec_lib/redis_connector.py b/bec_lib/bec_lib/redis_connector.py index 8734526c..a2fb0b95 100644 --- a/bec_lib/bec_lib/redis_connector.py +++ b/bec_lib/bec_lib/redis_connector.py @@ -570,12 +570,14 @@ class RedisConnector(ConnectorBase): fnmatch.filter(self._stream_topics_subscription, pattern), cb ) pubsub_unsubscribe_list = self._filter_topics_cb(patterns, cb) - self._pubsub_conn.punsubscribe(pubsub_unsubscribe_list) + if pubsub_unsubscribe_list: + self._pubsub_conn.punsubscribe(pubsub_unsubscribe_list) else: topics, _ = self._convert_endpointinfo(topics, check_message_op=False) if not self._unregister_stream(topics, cb): unsubscribe_list = self._filter_topics_cb(topics, cb) - self._pubsub_conn.unsubscribe(unsubscribe_list) + if unsubscribe_list: + self._pubsub_conn.unsubscribe(unsubscribe_list) def _unregister_stream(self, topics: list[str], cb: callable = None) -> bool: """