fix

raulb · raulb · commit bb0fbb58c976 · 2024-01-25T18:22:23.000+01:00
diff --git a/pkg/processor/procbuiltin/unwrap.go b/pkg/processor/procbuiltin/unwrap.go
@@ -151,7 +151,7 @@ func (o *openCDCUnwrapper) Unwrap(rec record.Record) (record.Record, error) {
 			Before: nil,
 			After:  structPayload,
 		},
-		Operation: record.OperationSnapshot,
+		Operation: o.UnwrapsOperation(rec),
 	}, nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -151,7 +151,7 @@ func (o *openCDCUnwrapper) Unwrap(rec record.Record) (record.Record, error) {`
`151`	`151`	`Before: nil,`
`152`	`152`	`After: structPayload,`
`153`	`153`	`},`
`154`		`- Operation: record.OperationSnapshot,`
	`154`	`+ Operation: o.UnwrapsOperation(rec),`
`155`	`155`	`}, nil`
`156`	`156`	`}`
`157`	`157`