more diag

FGasper · FGasper · commit 35bbfb44da60 · 2024-11-22T01:46:21.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -65,7 +65,7 @@ func (verifier *Verifier) HandleChangeStreamEvents(ctx context.Context, batch []
 		var changeEvent ParsedEvent
 		err := bson.Unmarshal(rawChangeEvent, &changeEvent)
 		if err != nil {
-			return errors.Wrapf(err, "failed to unmarshal change event (%+v) to %T", rawChangeEvent, changeEvent)
+			return errors.Wrapf(err, "failed to unmarshal change event %d of %d (%+v) to %T", 1+i, len(batch), rawChangeEvent, changeEvent)
 		}
 
 		if changeEvent.ClusterTime != nil &&

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ func (verifier *Verifier) HandleChangeStreamEvents(ctx context.Context, batch []`
`65`	`65`	`var changeEvent ParsedEvent`
`66`	`66`	`err := bson.Unmarshal(rawChangeEvent, &changeEvent)`
`67`	`67`	`if err != nil {`
`68`		`- return errors.Wrapf(err, "failed to unmarshal change event (%+v) to %T", rawChangeEvent, changeEvent)`
	`68`	`+ return errors.Wrapf(err, "failed to unmarshal change event %d of %d (%+v) to %T", 1+i, len(batch), rawChangeEvent, changeEvent)`
`69`	`69`	`}`
`70`	`70`
`71`	`71`	`if changeEvent.ClusterTime != nil &&`