From a5acf919e51f94d62c5a67eb7636d56e9a1e8dd1 Mon Sep 17 00:00:00 2001 From: Ramin Gharib Date: Wed, 10 Jul 2024 11:35:31 +0200 Subject: [PATCH] Add debug logs --- kpops/components/streams_bootstrap/producer/producer_app.py | 4 ++++ kpops/components/streams_bootstrap/streams/streams_app.py | 1 + 2 files changed, 5 insertions(+) diff --git a/kpops/components/streams_bootstrap/producer/producer_app.py b/kpops/components/streams_bootstrap/producer/producer_app.py index 7576eb0fb..7d97d8a30 100644 --- a/kpops/components/streams_bootstrap/producer/producer_app.py +++ b/kpops/components/streams_bootstrap/producer/producer_app.py @@ -1,3 +1,4 @@ +import logging from functools import cached_property from pydantic import Field, computed_field @@ -17,6 +18,8 @@ from kpops.components.streams_bootstrap.producer.model import ProducerAppValues from kpops.utils.docstring import describe_attr +log = logging.getLogger("ProducerApp") + class ProducerAppCleaner(KafkaAppCleaner): app: ProducerAppValues @@ -40,6 +43,7 @@ async def update_cleaner_with_cluster_values(self): if cluster_values: self.app = ProducerAppValues.model_validate(cluster_values) self.app.name_override = self.helm_name_override + log.debug("Updated producer cleaner with cluster values") class ProducerApp(KafkaApp, StreamsBootstrap): diff --git a/kpops/components/streams_bootstrap/streams/streams_app.py b/kpops/components/streams_bootstrap/streams/streams_app.py index b71ad32ad..803372a10 100644 --- a/kpops/components/streams_bootstrap/streams/streams_app.py +++ b/kpops/components/streams_bootstrap/streams/streams_app.py @@ -54,6 +54,7 @@ async def update_cleaner_with_cluster_values(self) -> None: if cluster_values: self.app = StreamsAppValues.model_validate(cluster_values) self.app.name_override = self.helm_name_override + log.debug("Updated streams cleaner with cluster values") async def clean_pvcs(self, dry_run: bool) -> None: app_full_name = super(HelmApp, self).full_name