From c9b6f5ecedb89ba219a124e674a6cb9cf9ff6e35 Mon Sep 17 00:00:00 2001 From: David Perl Date: Thu, 18 Jun 2026 09:25:48 +0200 Subject: [PATCH] chore: rename buffered to managed --- bec_widgets/utils/bec_dispatcher.py | 6 +++--- tests/unit_tests/test_bec_dispatcher.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/bec_widgets/utils/bec_dispatcher.py b/bec_widgets/utils/bec_dispatcher.py index 66092d9b..0e56e044 100644 --- a/bec_widgets/utils/bec_dispatcher.py +++ b/bec_widgets/utils/bec_dispatcher.py @@ -12,7 +12,7 @@ import redis from bec_lib.client import BECClient from bec_lib.logger import bec_logger from bec_lib.redis_connector import MessageObject, RedisConnector -from bec_lib.redis_connector.buffered_redis_connector import BufferedRedisConnector +from bec_lib.redis_connector.managed_redis_connection import ManagedRedisConnection from bec_lib.service_config import ServiceConfig from qtpy.QtCore import QObject from qtpy.QtCore import Signal as pyqtSignal @@ -100,7 +100,7 @@ class QtThreadSafeCallback(QObject): self.cb_signal.emit(msg_content, metadata) -class QtBufferedRedisConnector(BufferedRedisConnector): +class QtManagedRedisConnection(ManagedRedisConnection): def _execute_callback(self, cb, msg, kwargs): if not isinstance(cb, QtThreadSafeCallback): return super()._execute_callback(cb, msg, kwargs) @@ -123,7 +123,7 @@ class QtBufferedRedisConnector(BufferedRedisConnector): class QtRedisConnector(RedisConnector): - connector_cls = QtBufferedRedisConnector + connector_cls = QtManagedRedisConnection class BECDispatcher: diff --git a/tests/unit_tests/test_bec_dispatcher.py b/tests/unit_tests/test_bec_dispatcher.py index 3d6df87f..85acda48 100644 --- a/tests/unit_tests/test_bec_dispatcher.py +++ b/tests/unit_tests/test_bec_dispatcher.py @@ -240,7 +240,7 @@ def test_qt_redis_connector_logs_rpc_before_qt_callback(monkeypatch): ) try: - connector._buffered_connection._execute_callback(cb, {"data": rpc_msg}, {}) + connector._managed_connection._execute_callback(cb, {"data": rpc_msg}, {}) info_mock.assert_called_once() info_message = info_mock.call_args.args[0]