fix: tf metaErr

brexhq · Oct 25, 2023 · dcee46b · dcee46b
1 parent 3342f64
commit dcee46b
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/transform/meta_err.go b/transform/meta_err.go
@@ -57,7 +57,12 @@ type metaErr struct {
 }
 
 func (tf *metaErr) Transform(ctx context.Context, msg *message.Message) ([]*message.Message, error) {
-	msgs, _ := tf.tf.Transform(ctx, msg)
+	msgs, err := tf.tf.Transform(ctx, msg)
+	if err != nil {
+		//nolint: nilerr // ignore non-nil error
+		return []*message.Message{msg}, nil
+	}
+
 	return msgs, nil
 }