Minor additional logging improvements

2 files changed, 5 insertions, 8 deletions

diff --git a/robusta_krr/core/integrations/prometheus/connector.py b/robusta_krr/core/integrations/prometheus/connector.py
index d75050f..8020c2e 100644
--- a/robusta_krr/core/integrations/prometheus/connector.py
+++ b/robusta_krr/core/integrations/prometheus/connector.py
@@ -58,14 +58,9 @@ class PrometheusConnector:
 
     def connect(self, url: Optional[str] = None) -> None:
         """Connect to a Prometheus service using a URL."""
-        try:
-            loader = PrometheusMetricsService(url=url)
-            self._connect(loader)
-        except Exception as e:
-            logger.warning(f"Unable to connect to Prometheus using the provided URL ({e})")
-            raise e
-        else:
-            logger.info(f"{loader.name()} connected successfully")
+        loader = PrometheusMetricsService(url=url)
+        self._connect(loader)
+        logger.info(f"{loader.name()} connected successfully")
 
     def _connect(self, loader: PrometheusMetricsService) -> None:
         service_name = loader.name()
diff --git a/robusta_krr/core/runner.py b/robusta_krr/core/runner.py
index 75c2191..a52f1be 100644
--- a/robusta_krr/core/runner.py
+++ b/robusta_krr/core/runner.py
@@ -247,6 +247,8 @@ class Runner:
 
     async def _collect_result(self) -> Result:
         clusters = await self.connector.list_clusters()
+        logger.info(f"Clusters available: {', '.join(clusters)}")
+
         if clusters and len(clusters) > 1 and settings.prometheus_url:
             # this can only happen for multi-cluster querying a single centeralized prometheus
             # In this scenario we dont yet support determining