|
1 | 1 | import { strict as assert } from 'assert';
|
| 2 | +import { UUID } from 'bson'; |
2 | 3 | import { expect } from 'chai';
|
3 | 4 | import { on, once } from 'events';
|
4 | 5 | import { gte, lt } from 'semver';
|
@@ -27,7 +28,6 @@ import * as mock from '../../tools/mongodb-mock/index';
|
27 | 28 | import { TestBuilder, UnifiedTestSuiteBuilder } from '../../tools/unified_suite_builder';
|
28 | 29 | import { type FailCommandFailPoint, sleep } from '../../tools/utils';
|
29 | 30 | import { delay, filterForCommands } from '../shared';
|
30 |
| -import { UUID } from 'bson'; |
31 | 31 |
|
32 | 32 | const initIteratorMode = async (cs: ChangeStream) => {
|
33 | 33 | const initEvent = once(cs.cursor, 'init');
|
@@ -2261,7 +2261,6 @@ describe('ChangeStream resumability', function () {
|
2261 | 2261 | });
|
2262 | 2262 |
|
2263 | 2263 | context('when the error is not a server error', function () {
|
2264 |
| - // This test requires a replica set to call replSetFreeze command |
2265 | 2264 | it(
|
2266 | 2265 | 'should resume on ServerSelectionError',
|
2267 | 2266 | { requires: { topology: ['replicaset'] } },
|
@@ -2607,7 +2606,6 @@ describe('ChangeStream resumability', function () {
|
2607 | 2606 | });
|
2608 | 2607 |
|
2609 | 2608 | context('when the error is not a server error', function () {
|
2610 |
| - // This test requires a replica set to call replSetFreeze command |
2611 | 2609 | it(
|
2612 | 2610 | 'should resume on ServerSelectionError',
|
2613 | 2611 | { requires: { topology: ['replicaset'] } },
|
@@ -2775,7 +2773,6 @@ describe('ChangeStream resumability', function () {
|
2775 | 2773 | });
|
2776 | 2774 |
|
2777 | 2775 | context('when the error is not a server error', function () {
|
2778 |
| - // This test requires a replica set to call replSetFreeze command |
2779 | 2776 | it(
|
2780 | 2777 | 'should resume on ServerSelectionError',
|
2781 | 2778 | { requires: { topology: ['replicaset'] } },
|
|
0 commit comments