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()