Add debug logs

bakdata · Jul 10, 2024 · a5acf91 · a5acf91
1 parent ee26280
commit a5acf91
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git 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
@@ -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