Update tag_processor_plugin/tag_processor_plugin.go

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
united-manufacturing-hub · Feb 13, 2025 · 37cad71 · 37cad71
1 parent 4a0c2d5
commit 37cad71
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tag_processor_plugin/tag_processor_plugin.go b/tag_processor_plugin/tag_processor_plugin.go
@@ -590,14 +590,16 @@ func (p *TagProcessor) constructFinalMessage(msg *service.Message) (*service.Mes
 	}
 	if exposeAll {
 		allMeta := make(map[string]string)
-		_ = msg.MetaWalkMut(func(key string, value any) error {
+		if err := msg.MetaWalkMut(func(key string, value any) error {
 			if str, ok := value.(string); ok {
 				allMeta[key] = str
 			} else {
 				allMeta[key] = fmt.Sprintf("%v", value)
 			}
 			return nil
-		})
+		}); err != nil {
+			return nil, fmt.Errorf("failed to collect all metadata: %v", err)
+		}
 		finalPayload["meta"] = allMeta
 	} else if len(filteredMeta) > 0 {
 		finalPayload["meta"] = filteredMeta