refactor: simplify structlog and use structlog.get_logger directly

Consolidate logging into utilities/logger.py: ProcessorFormatter with
ConsoleRenderer (console) and JSONRenderer (file), configure_structlog() in
setup_logging(), and _StructlogQueueHandler so event dicts survive the queue.

Remove utilities/opendatahub_logger.py. Replace get_logger() wrapper with
import structlog and structlog.get_logger(name=__name__) across tests and
utilities.

Signed-off-by: Jorge Garcia Oncins <jgarciao@redhat.com>
Made-with: Cursor
Signed-off-by: Jorge Garcia Oncins <jgarciao@redhat.com>

Author: jgarciao

tests/cluster_health/test_cluster_health.py

@@ -1,10 +1,9 @@
 import pytest
+import structlog
 from ocp_resources.node import Node
 from ocp_utilities.infra import assert_nodes_in_healthy_condition, assert_nodes_schedulable
 
-from utilities.opendatahub_logger import get_logger
-
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 @pytest.mark.cluster_health

tests/cluster_health/test_operator_health.py

@@ -1,14 +1,14 @@
 import pytest
+import structlog
 from kubernetes.dynamic import DynamicClient
 from ocp_resources.data_science_cluster import DataScienceCluster
 from ocp_resources.dsc_initialization import DSCInitialization
 from pytest_testconfig import config as py_config
 
 from utilities.general import wait_for_pods_running
 from utilities.infra import wait_for_dsc_status_ready, wait_for_dsci_status_ready
-from utilities.opendatahub_logger import get_logger
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 @pytest.mark.operator_health

tests/conftest.py

@@ -9,6 +9,7 @@
 
 import pytest
 import shortuuid
+import structlog
 import yaml
 from _pytest._py.path import LocalPath
 from _pytest.legacypath import TempdirFactory
@@ -64,12 +65,11 @@
 from utilities.logger import RedactedString
 from utilities.mariadb_utils import wait_for_mariadb_operator_deployments
 from utilities.minio import create_minio_data_connection_secret
-from utilities.opendatahub_logger import get_logger
 from utilities.operator_utils import get_cluster_service_version, get_csv_related_images
 from utilities.serving_runtime import get_runtime_image_from_template
 from utilities.user_utils import get_byoidc_issuer_url, get_oidc_tokens
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 pytest_plugins = [
     "tests.fixtures.inference",

tests/fixtures/inference.py

@@ -2,6 +2,7 @@
 from typing import Any
 
 import pytest
+import structlog
 from kubernetes.dynamic import DynamicClient
 from ocp_resources.data_science_cluster import DataScienceCluster
 from ocp_resources.deployment import Deployment
@@ -23,10 +24,9 @@
 )
 from utilities.inference_utils import create_isvc
 from utilities.infra import get_data_science_cluster, wait_for_dsc_status_ready
-from utilities.opendatahub_logger import get_logger
 from utilities.serving_runtime import ServingRuntimeFromTemplate
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 @pytest.fixture(scope="class")

tests/llama_stack/conftest.py

@@ -4,6 +4,7 @@
 
 import httpx
 import pytest
+import structlog
 from _pytest.fixtures import FixtureRequest
 from kubernetes.dynamic import DynamicClient
 from llama_stack_client import APIError, LlamaStackClient
@@ -42,10 +43,9 @@
 from utilities.constants import Annotations, DscComponents
 from utilities.data_science_cluster_utils import update_components_in_dsc
 from utilities.general import generate_random_name
-from utilities.opendatahub_logger import get_logger
 from utilities.resources.llama_stack_distribution import LlamaStackDistribution
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 pytestmark = pytest.mark.skip_on_disconnected
 

tests/llama_stack/inference/test_completions.py

@@ -1,10 +1,10 @@
 import pytest
+import structlog
 from llama_stack_client import LlamaStackClient
 
 from tests.llama_stack.constants import ModelInfo
-from utilities.opendatahub_logger import get_logger
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 @pytest.mark.parametrize(

tests/llama_stack/safety/test_trustyai_fms_provider.py

@@ -1,11 +1,11 @@
 import pytest
+import structlog
 import yaml
 
 from tests.llama_stack.constants import LlamaStackProviders
 from utilities.constants import BUILTIN_DETECTOR_CONFIG, CHAT_GENERATION_CONFIG, QWEN_MODEL_NAME, MinIo
-from utilities.opendatahub_logger import get_logger
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 SECURE_SHIELD_ID: str = "secure_shield"
 
 

tests/llama_stack/utils.py

@@ -7,6 +7,7 @@
 from typing import Any
 
 import requests
+import structlog
 from kubernetes.dynamic import DynamicClient
 from kubernetes.dynamic.exceptions import ResourceNotFoundError
 from llama_stack_client import APIConnectionError, InternalServerError, LlamaStackClient
@@ -19,11 +20,10 @@
     LLS_CORE_POD_FILTER,
 )
 from utilities.exceptions import UnexpectedResourceCountError
-from utilities.opendatahub_logger import get_logger
 from utilities.path_utils import resolve_repo_path
 from utilities.resources.llama_stack_distribution import LlamaStackDistribution
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 def _assert_file_uploaded(uploaded_file: File, expected_purpose: str) -> None:

tests/llama_stack/vector_io/test_vector_stores.py

@@ -1,4 +1,5 @@
 import pytest
+import structlog
 from llama_stack_client import LlamaStackClient
 from llama_stack_client.types.vector_store import VectorStore
 
@@ -8,9 +9,8 @@
     IBM_EARNINGS_SEARCH_QUERIES_BY_MODE,
     ModelInfo,
 )
-from utilities.opendatahub_logger import get_logger
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 @pytest.mark.parametrize(

tests/model_explainability/evalhub/conftest.py

@@ -2,17 +2,17 @@
 from typing import Any
 
 import pytest
+import structlog
 from kubernetes.dynamic import DynamicClient
 from ocp_resources.deployment import Deployment
 from ocp_resources.namespace import Namespace
 from ocp_resources.route import Route
 
 from utilities.certificates_utils import create_ca_bundle_file
 from utilities.constants import Timeout
-from utilities.opendatahub_logger import get_logger
 from utilities.resources.evalhub import EvalHub
 
-LOGGER = get_logger(name=__name__)
+LOGGER = structlog.get_logger(name=__name__)
 
 
 @pytest.fixture(scope="class")