Fix test config endless load (#798)

* fixed bug

* added changelog entry

---------

Co-authored-by: kmeinerz1 <kaithomas.meinerz@bwi.de>

Author: kmeinerz

CHANGELOG.md

@@ -10,6 +10,7 @@
 ### Bugfix
 
 - Fixed logging error in _revoke_callback() by adding error handling
+- Fixed endless loading in logprep test config
 
 ## 16.1.0
 ### Deprecations

logprep/run_logprep.py

@@ -17,6 +17,7 @@
 from logprep.util.configuration import Configuration, InvalidConfigurationError
 from logprep.util.defaults import DEFAULT_LOG_CONFIG, EXITCODES
 from logprep.util.helper import get_versions_string, print_fcolor
+from logprep.util.logging import LogprepMPQueueListener, logqueue
 from logprep.util.pseudo.commands import depseudonymize, generate_keys, pseudonymize
 from logprep.util.rule_dry_runner import DryRunner
 
@@ -37,7 +38,14 @@ def _get_configuration(config_paths: tuple[str]) -> Configuration:
         config = Configuration.from_sources(config_paths)
         config.logger.setup_logging()
         logger = logging.getLogger("root")  # pylint: disable=redefined-outer-name
+
+        console_logger = logging.getLogger("console")
+        console_handler = console_logger.handlers[0]
+        listener = LogprepMPQueueListener(logqueue, console_handler)
+        listener.start()
+
         logger.info(f"Log level set to '{logging.getLevelName(logger.level)}'")
+        listener.stop()
         return config
     except InvalidConfigurationError as error:
         print(f"InvalidConfigurationError: {error}", file=sys.stderr)
@@ -62,7 +70,7 @@ def cli() -> None:
     "--version",
     is_flag=True,
     default=False,
-    help="Print version and exit (includes also congfig version)",
+    help="Print version and exit (includes also config version)",
 )
 def run(configs: tuple[str], version=None) -> None:
     """

tests/unit/test_run_logprep.py

@@ -122,6 +122,17 @@ def test_test_config_verifies_configuration_successfully(self, mock_verify):
         mock_verify.assert_called()
         assert "The verification of the configuration was successful" in result.stdout
 
+    @mock.patch("logprep.run_logprep.LogprepMPQueueListener")
+    def test_listener_start_and_stop_called(self, mock_listener_cls):
+        mock_listener = mock.Mock()
+        mock_listener_cls.return_value = mock_listener
+
+        args = ["test", "config", "tests/testdata/config/config.yml"]
+        result = self.cli_runner.invoke(cli, args)
+
+        assert mock_listener.start.called, "Listener start() was not called"
+        assert mock_listener.stop.called, "Listener stop() was not called"
+
     @mock.patch("logprep.util.configuration.Configuration._verify")
     def test_test_config_verifies_configuration_unsuccessfully(self, mock_verify):
         mock_verify.side_effect = InvalidConfigurationError("test error")