loggin

FGasper · FGasper · commit f5e6c4a249c2 · 2025-11-04T02:18:31.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -176,6 +176,7 @@ HandlerLoop:
 			)
 
 			if err == nil && batch.resumeToken != nil {
+				fmt.Printf("--- batch persisted: %+v\n", batch.events)
 				persistResumeTokenIfNeeded(ctx, batch.resumeToken)
 			}
 		}
diff --git a/internal/verifier/change_stream_test.go b/internal/verifier/change_stream_test.go
@@ -373,7 +373,11 @@ func (suite *IntegrationTestSuite) TestChangeStream_Resume_NoSkip() {
 	)
 
 	rechecks := suite.fetchVerifierRechecks(ctx, verifier2)
-	assert.EqualValues(suite.T(), len(rechecks), lastDocID, "all source docs should be rechecked")
+	if !assert.EqualValues(suite.T(), len(rechecks), lastDocID, "all source docs should be rechecked") {
+		for _, recheck := range rechecks {
+			suite.T().Logf("found recheck: %v", recheck)
+		}
+	}
 }
 
 // TestChangeStreamResumability creates a verifier, starts its change stream,

Original file line number	Diff line number	Diff line change
`@@ -176,6 +176,7 @@ HandlerLoop:`
`176`	`176`	`)`
`177`	`177`
`178`	`178`	`if err == nil && batch.resumeToken != nil {`
	`179`	`+ fmt.Printf("--- batch persisted: %+v\n", batch.events)`
`179`	`180`	`persistResumeTokenIfNeeded(ctx, batch.resumeToken)`
`180`	`181`	`}`
`181`	`182`	`}`
Original file line number	Diff line number	Diff line change
`@@ -373,7 +373,11 @@ func (suite *IntegrationTestSuite) TestChangeStream_Resume_NoSkip() {`
`373`	`373`	`)`
`374`	`374`
`375`	`375`	`rechecks := suite.fetchVerifierRechecks(ctx, verifier2)`
`376`		`- assert.EqualValues(suite.T(), len(rechecks), lastDocID, "all source docs should be rechecked")`
	`376`	`+ if !assert.EqualValues(suite.T(), len(rechecks), lastDocID, "all source docs should be rechecked") {`
	`377`	`+ for _, recheck := range rechecks {`
	`378`	`+ suite.T().Logf("found recheck: %v", recheck)`
	`379`	`+ }`
	`380`	`+ }`
`377`	`381`	`}`
`378`	`382`
`379`	`383`	`// TestChangeStreamResumability creates a verifier, starts its change stream,`