Disable rich markup if rich handler is not present

kedro/io/data_catalog.py

@@ -24,6 +24,7 @@
     generate_timestamp,
 )
 from kedro.io.memory_dataset import MemoryDataset
+from kedro.logging import _format_rich, _has_rich_handler
 
 Patterns = Dict[str, Dict[str, Any]]
 
@@ -521,8 +522,10 @@ def load(self, name: str, version: str | None = None) -> Any:
         dataset = self._get_dataset(name, version=load_version)
 
         self._logger.info(
-            "Loading data from [dark_orange]%s[/dark_orange] (%s)...",
-            name,
+            "Loading data from %s (%s)...",
+            _format_rich(name, "dark_orange")
+            if _has_rich_handler(self._logger)
+            else name,
             type(dataset).__name__,
             extra={"markup": True},
         )
@@ -563,8 +566,10 @@ def save(self, name: str, data: Any) -> None:
         dataset = self._get_dataset(name)
 
         self._logger.info(
-            "Saving data to [dark_orange]%s[/dark_orange] (%s)...",
-            name,
+            "Saving data to %s (%s)...",
+            _format_rich(name, "dark_orange")
+            if _has_rich_handler(self._logger)
+            else name,
             type(dataset).__name__,
             extra={"markup": True},
         )

kedro/logging.py

@@ -1,5 +1,6 @@
 import logging
 import sys
+from functools import lru_cache
 from pathlib import Path
 from typing import Any
 
@@ -54,3 +55,14 @@ def __init__(self, *args: Any, **kwargs: Any):
             # fixed on their side at some point, but until then we disable it.
             # See https://github.com/Textualize/rich/issues/2455
             rich.traceback.install(**traceback_install_kwargs)  # type: ignore[arg-type]
+
+
+@lru_cache(maxsize=None)
+def _has_rich_handler(logger: logging.Logger) -> bool:
+    """Returns true if the logger has a RichHandler attached."""
+    return any(isinstance(handler, RichHandler) for handler in logger.handlers)
+
+
+def _format_rich(value: str, markup: str) -> str:
+    """Format string with rich markup"""
+    return f"[{markup}]{value}[/{markup}]"

tests/framework/project/test_logging.py

@@ -6,6 +6,7 @@
 import yaml
 
 from kedro.framework.project import LOGGING, configure_logging, configure_project
+from kedro.logging import RichHandler, _format_rich, _has_rich_handler
 
 
 @pytest.fixture
@@ -35,20 +36,18 @@ def test_project_logging_in_default_logging_config(default_logging_config_with_p
     assert logging.getLogger("test_project").level == logging.INFO
 
 
-def test_environment_variable_logging_config(monkeypatch, tmp_path, caplog):
-    config_path = (Path(tmp_path) / "logging.yml").absolute()
-    monkeypatch.setenv("KEDRO_LOGGING_CONFIG", config_path)
-    logging_config = {"version": 1, "loggers": {"kedro": {"level": "DEBUG"}}}
+def test_environment_variable_logging_config(monkeypatch, tmp_path):
+    config_path = Path(tmp_path) / "logging.yml"
+    monkeypatch.setenv("KEDRO_LOGGING_CONFIG", config_path.absolute())
+    logging_config = {"version": 1, "loggers": {"kedro": {"level": "WARNING"}}}
     with config_path.open("w", encoding="utf-8") as f:
         yaml.dump(logging_config, f)
     from kedro.framework.project import _ProjectLogging
 
     LOGGING = _ProjectLogging()
 
     assert LOGGING.data == logging_config
-    assert logging.getLogger("kedro").level == logging.DEBUG
-    expected_message = f"Using '{config_path}'"
-    assert expected_message in "".join(caplog.messages).strip("\n")
+    assert logging.getLogger("kedro").level == logging.WARNING
 
 
 def test_configure_logging():
@@ -148,7 +147,22 @@ def test_rich_traceback_disabled_on_databricks(
     rich_pretty_install.assert_called()
 
 
-def test_environment_variable_logging_config2(monkeypatch, tmp_path, caplog):
+def test_rich_format():
+    assert (
+        _format_rich("Hello World!", "dark_orange")
+        == "[dark_orange]Hello World![/dark_orange]"
+    )
+
+
+def test_has_rich_handler():
+    test_logger = logging.getLogger("test_logger")
+    assert not _has_rich_handler(test_logger)
+    _has_rich_handler.cache_clear()
+    test_logger.addHandler(RichHandler())
+    assert _has_rich_handler(test_logger)
+
+
+def test_default_logging_info_emission(monkeypatch, tmp_path, caplog):
     config_path = (Path(tmp_path) / "conf" / "logging.yml").absolute()
     config_path.parent.mkdir(parents=True)
     logging_config = {"version": 1, "loggers": {"kedro": {"level": "DEBUG"}}}