More logging.

GoogleCloudPlatform · Jul 26, 2024 · 15dbcc9 · 15dbcc9
1 parent 7e089fd
commit 15dbcc9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/receiver/dcgmreceiver/scraper.go b/receiver/dcgmreceiver/scraper.go
@@ -180,14 +180,21 @@ func (s *dcgmScraper) scrape(_ context.Context) (pmetric.Metrics, error) {
 		return s.mb.Emit(), err
 	}
 
+	s.settings.Logger.Sugar().Info(fmt.Sprintf("Client created: %v; collecting metrics", s.client))
 	deviceMetrics, err := s.client.collectDeviceMetrics()
+	if err != nil {
+		s.settings.Logger.Sugar().Warn(fmt.Sprintf("Metrics not collected; err=%v", err))
+		return s.mb.Emit(), err
+	}
 
 	now := pcommon.NewTimestampFromTime(time.Now())
+	s.settings.Logger.Sugar().Info(fmt.Sprintf("Metrics collected: %d", len(deviceMetrics)))
 	for gpuIndex, gpuMetrics := range deviceMetrics {
 		metricsByName := make(map[string][]dcgmMetric)
 		for _, metric := range gpuMetrics {
 			metricsByName[metric.name] = append(metricsByName[metric.name], metric)
 		}
+		s.settings.Logger.Sugar().Warn(fmt.Sprintf("Got %d unique metrics: %v", len(metricsByName), metricsByName))
 		metrics := make(map[string]dcgmMetric)
 		for name, points := range metricsByName {
 			slices.SortStableFunc(points, func(a, b dcgmMetric) int {