diff --git a/pkg/transform/transform.go b/pkg/transform/transform.go index 5f9e202f..976d735b 100644 --- a/pkg/transform/transform.go +++ b/pkg/transform/transform.go @@ -94,8 +94,11 @@ func NewTransformation(tranformFunctions ...TransformationFunction) Transformati if failure != nil { failureList = append(failureList, failure) + if failure.Meta == nil { + failure.Meta = make(map[string]interface{}) + } failure.Meta["transformation_error"] = failure.GetError().Error() - metaJSON, err := json.Marshal(filtered.Meta) + metaJSON, err := json.Marshal(failure.Meta) if err != nil { fmt.Println("ERROR MARSHALING FILTER META: " + err.Error()) }