Skip to content

Commit 229ac9a

Browse files
committed
tweak
1 parent 63f6754 commit 229ac9a

File tree

1 file changed

+3
-11
lines changed

1 file changed

+3
-11
lines changed

internal/verifier/clustertime.go

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ import (
55

66
"github.com/10gen/migration-verifier/internal/logger"
77
"github.com/10gen/migration-verifier/internal/retry"
8-
"github.com/10gen/migration-verifier/internal/util"
98
"github.com/10gen/migration-verifier/mbson"
109
"github.com/pkg/errors"
1110
"go.mongodb.org/mongo-driver/bson"
@@ -71,22 +70,15 @@ func fetchNewClusterTime(
7170
ctx context.Context,
7271
client *mongo.Client,
7372
) (primitive.Timestamp, error) {
74-
cmd, rawResponse, err := runAppendOplogNote(
73+
_, rawResponse, err := runAppendOplogNote(
7574
ctx,
7675
client,
7776
"expect StaleClusterTime error",
7877
)
79-
80-
// We expect an error here; if we didn't get one then something is
81-
// amiss on the server.
82-
if err == nil {
83-
return primitive.Timestamp{}, errors.Errorf("server request unexpectedly succeeded: %v", cmd)
84-
}
85-
86-
if !util.IsStaleClusterTimeError(err) {
78+
if err != nil {
8779
return primitive.Timestamp{}, errors.Wrap(
8880
err,
89-
"unexpected error (expected StaleClusterTime) from request",
81+
"failed to append note to oplog",
9082
)
9183
}
9284

0 commit comments

Comments
 (0)