Skip to content

Commit 0bee1e2

Browse files
committed
more delay
1 parent 3252621 commit 0bee1e2

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

internal/verifier/migration_verifier_test.go

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1199,8 +1199,12 @@ func (suite *IntegrationTestSuite) TestVerifierNamespaceList() {
11991199
suite.Require().NoError(err)
12001200
err = suite.dstMongoClient.Database("testDb4").CreateCollection(ctx, "testColl6")
12011201
suite.Require().NoError(err)
1202-
err = suite.dstMongoClient.Database("local").CreateCollection(ctx, "testColl7")
1203-
suite.Require().NoError(err)
1202+
1203+
if suite.GetSrcTopology() != TopologySharded {
1204+
err = suite.dstMongoClient.Database("local").CreateCollection(ctx, "testColl7")
1205+
suite.Require().NoError(err)
1206+
}
1207+
12041208
err = suite.dstMongoClient.Database("mongosync_reserved_for_internal_use").CreateCollection(ctx, "globalState")
12051209
suite.Require().NoError(err)
12061210
err = suite.dstMongoClient.Database("mongosync_reserved_for_verification_src_metadata").CreateCollection(ctx, "auditor")
@@ -1317,7 +1321,11 @@ func (suite *IntegrationTestSuite) TestGenerationalRechecking() {
13171321
suite.Require().NoError(err)
13181322

13191323
for status.TotalTasks == 0 && verifier.generation < 10 {
1320-
suite.T().Logf("TotalTasks is 0 (generation=%d); waiting another generation …", verifier.generation)
1324+
delay := time.Second
1325+
1326+
suite.T().Logf("TotalTasks is 0 (generation=%d); waiting %s then will run another generation …", verifier.generation, delay)
1327+
1328+
time.Sleep(delay)
13211329
checkContinueChan <- struct{}{}
13221330
<-checkDoneChan
13231331
status, err = verifier.GetVerificationStatus()

0 commit comments

Comments
 (0)