just one test

FGasper · FGasper · commit 66dbb3100963 · 2024-11-22T01:41:38.000-05:00
diff --git a/.github/workflows/all.yml b/.github/workflows/all.yml
@@ -88,7 +88,7 @@ jobs:
             } | parallel
 
       - name: Test
-        run: go test -v ./... -race
+        run: go test -v ./... -race -testify.m TestEventBeforeWritesOff
         env:
           MVTEST_SRC: ${{matrix.topology.srcConnStr}}
           MVTEST_DST: ${{matrix.topology.dstConnStr}}
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -170,6 +170,8 @@ func (verifier *Verifier) readAndHandleOneChangeEventBatch(
 			changeEventBatch = make([]bson.Raw, cs.RemainingBatchLength()+1)
 		}
 
+		fmt.Printf("\n===== event: %+v\n", cs.Current)
+
 		// NB: Decode() achieves a deep-clone of cs.Current.
 		if err := cs.Decode(&changeEventBatch[eventsRead]); err != nil {
 			return errors.Wrap(err, "failed to decode change event")

Original file line number	Diff line number	Diff line change
`@@ -170,6 +170,8 @@ func (verifier *Verifier) readAndHandleOneChangeEventBatch(`
`170`	`170`	`changeEventBatch = make([]bson.Raw, cs.RemainingBatchLength()+1)`
`171`	`171`	`}`
`172`	`172`
	`173`	`+ fmt.Printf("\n===== event: %+v\n", cs.Current)`
	`174`	`+`
`173`	`175`	`// NB: Decode() achieves a deep-clone of cs.Current.`
`174`	`176`	`if err := cs.Decode(&changeEventBatch[eventsRead]); err != nil {`
`175`	`177`	`return errors.Wrap(err, "failed to decode change event")`