Fix iteration (#2193)

* fix(maestro): fix iteration to be more performatic and less error prone. Signed-off-by: Luiz Pegoraro <[email protected]> * fix(maestro): fix nil reference error Signed-off-by: Luiz Pegoraro <[email protected]> --------- Signed-off-by: Luiz Pegoraro <[email protected]>
orb-community · Feb 9, 2023 · affb48c · affb48c
1 parent 86db196
commit affb48c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/maestro/monitor/monitor.go b/maestro/monitor/monitor.go
@@ -161,8 +161,8 @@ func (svc *monitorService) monitorSinks(ctx context.Context) {
 	for _, collector := range runningCollectors {
 		var sink *sinkspb.SinkRes
 		for _, sinkRes := range sinksRes.Sinks {
-			svc.logger.Info("Debug collector name, collector id", zap.String("name", collector.Name), zap.Any("collector", collector))
-			if strings.Contains(collector.Name, sink.Id) {
+			svc.logger.Info("Debug collector name, collector id", zap.String("name", collector.Name), zap.String("sinkID", sinkRes.Id))
+			if strings.Contains(collector.Name, sinkRes.Id) {
 				sink = sinkRes
 				break
 			}