diff --git a/src/go/mongolib/util/util.go b/src/go/mongolib/util/util.go index 1f198862..b8460935 100644 --- a/src/go/mongolib/util/util.go +++ b/src/go/mongolib/util/util.go @@ -28,6 +28,7 @@ const ( shardingNotEnabledErrorCode = 203 ErrNotYetInitialized = int32(94) ErrNoReplicationEnabled = int32(76) + ErrNotPrimaryOrSecondary = int32(13436) ) var ( @@ -471,7 +472,8 @@ func ClusterID(ctx context.Context, client *mongo.Client) (string, error) { } func IsReplicationNotEnabledError(err mongo.CommandError) bool { - return err.Code == ErrNotYetInitialized || err.Code == ErrNoReplicationEnabled + return err.Code == ErrNotYetInitialized || err.Code == ErrNoReplicationEnabled || + err.Code == ErrNotPrimaryOrSecondary } func MyState(ctx context.Context, client *mongo.Client) (int, error) {