Skip to content

Commit ad9d109

Browse files
authored
fix: Set all fields in DeleteRecord message (#1316)
<!-- Explain what problem this PR addresses --> ---
1 parent e9c751c commit ad9d109

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

internal/servers/plugin/v3/plugin.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -270,6 +270,7 @@ func (s *Server) Write(stream pb.Plugin_WriteServer) error {
270270
whereClause := make(message.PredicateGroups, len(pbMsg.DeleteRecord.WhereClause))
271271

272272
for j, predicateGroup := range pbMsg.DeleteRecord.WhereClause {
273+
whereClause[j].GroupingType = predicateGroup.GroupingType.String()
273274
whereClause[j].Predicates = make(message.Predicates, len(predicateGroup.Predicates))
274275
for i, predicate := range predicateGroup.Predicates {
275276
record, err := pb.NewRecordFromBytes(predicate.Record)

0 commit comments

Comments
 (0)