Update integration_test_suite.go

tdq45gj · tdq45gj · commit 4ff9863f8314 · 2024-11-25T13:22:53.000-05:00
diff --git a/internal/verifier/integration_test_suite.go b/internal/verifier/integration_test_suite.go
@@ -185,6 +185,7 @@ func (suite *IntegrationTestSuite) BuildVerifier() *Verifier {
 	)
 	verifier.SetLogger("stderr")
 	verifier.SetMetaDBName(metaDBName)
+	verifier.initializeChangeStreamReaders()
 
 	suite.Require().NoError(verifier.srcClientCollection(&task).Drop(ctx))
 	suite.Require().NoError(verifier.dstClientCollection(&task).Drop(ctx))

Original file line number	Diff line number	Diff line change
`@@ -185,6 +185,7 @@ func (suite IntegrationTestSuite) BuildVerifier() Verifier {`
`185`	`185`	`)`
`186`	`186`	`verifier.SetLogger("stderr")`
`187`	`187`	`verifier.SetMetaDBName(metaDBName)`
	`188`	`+ verifier.initializeChangeStreamReaders()`
`188`	`189`
`189`	`190`	`suite.Require().NoError(verifier.srcClientCollection(&task).Drop(ctx))`
`190`	`191`	`suite.Require().NoError(verifier.dstClientCollection(&task).Drop(ctx))`