From 1eaefc1c8ab08e8c4939c05912d476b08bdcc2c9 Mon Sep 17 00:00:00 2001 From: wyzula-jan Date: Thu, 25 Apr 2024 16:39:03 +0200 Subject: [PATCH] fix(channel_monitor): register.start removed since connector.register do not have any .start method --- bec_lib/bec_lib/channel_monitor.py | 1 - bec_lib/tests/test_channel_monitor.py | 1 - 2 files changed, 2 deletions(-) diff --git a/bec_lib/bec_lib/channel_monitor.py b/bec_lib/bec_lib/channel_monitor.py index 38fb5deb..39245994 100644 --- a/bec_lib/bec_lib/channel_monitor.py +++ b/bec_lib/bec_lib/channel_monitor.py @@ -23,7 +23,6 @@ def _start_register(config_path, topic): config = ServiceConfig(config_path) connector = RedisConnector(config.redis) register = connector.register(topics=topic, cb=channel_callback) - register.start() event = threading.Event() event.wait() diff --git a/bec_lib/tests/test_channel_monitor.py b/bec_lib/tests/test_channel_monitor.py index 1b106a72..194f0f6a 100644 --- a/bec_lib/tests/test_channel_monitor.py +++ b/bec_lib/tests/test_channel_monitor.py @@ -27,5 +27,4 @@ def test_channel_monitor_start_register(): mock_connector.return_value = mock.MagicMock() channel_monitor_launch() mock_connector().register.assert_called_once() - mock_connector().register.return_value.start.assert_called_once() mock_threading.Event().wait.assert_called_once()