diff --git a/test/integration/retryable-reads/retryable_reads.spec.test.ts b/test/integration/retryable-reads/retryable_reads.spec.test.ts index 57b325f4208..19657f01e6d 100644 --- a/test/integration/retryable-reads/retryable_reads.spec.test.ts +++ b/test/integration/retryable-reads/retryable_reads.spec.test.ts @@ -12,12 +12,18 @@ const UNIMPLEMENTED_APIS = [ 'listDatabaseObjects' ]; +const skippedTests = ['collection.listIndexes succeeds after retryable handshake network error']; + describe('Retryable Reads (unified)', function () { runUnifiedSuite(loadSpecTests(path.join('retryable-reads', 'unified')), ({ description }) => { for (const apiName of UNIMPLEMENTED_APIS) { if (description.toLowerCase().includes(apiName.toLowerCase())) { return `The Node.js Driver does not support ${apiName}`; } + + if (skippedTests.includes(description)) { + return `TODO(NODE-6832): fix flaky retryable reads tests`; + } } return false; }); diff --git a/test/integration/server-discovery-and-monitoring/server_discovery_and_monitoring.prose.test.ts b/test/integration/server-discovery-and-monitoring/server_discovery_and_monitoring.prose.test.ts index ad8ade8c7dd..3549d580c69 100644 --- a/test/integration/server-discovery-and-monitoring/server_discovery_and_monitoring.prose.test.ts +++ b/test/integration/server-discovery-and-monitoring/server_discovery_and_monitoring.prose.test.ts @@ -146,37 +146,40 @@ describe('Server Discovery and Monitoring Prose Tests', function () { await client.close(); }); - it('ensure monitors properly create and unpause connection pools when they discover servers', { - metadata: { requires: { mongodb: '>=4.2.9', topology: '!load-balanced' } }, - test: async function () { - await client.connect(); - expect(events.shift()).to.equal(SERVER_HEARTBEAT_SUCCEEDED); - expect(events.shift()).to.equal(CONNECTION_POOL_READY); - - expect(events).to.be.empty; - - const heartBeatFailedEvent = once(client, SERVER_HEARTBEAT_FAILED); - await client.db('admin').command({ - configureFailPoint: 'failCommand', - mode: { times: 2 }, - data: { - failCommands: ['hello'], - errorCode: 1234, - appName: 'SDAMPoolManagementTest' - } - }); - await heartBeatFailedEvent; - expect(events.shift()).to.equal(SERVER_HEARTBEAT_FAILED); - expect(events.shift()).to.equal(CONNECTION_POOL_CLEARED); - - expect(events).to.be.empty; - - await once(client, SERVER_HEARTBEAT_SUCCEEDED); - expect(events.shift()).to.equal(SERVER_HEARTBEAT_SUCCEEDED); - expect(events.shift()).to.equal(CONNECTION_POOL_READY); - - expect(events).to.be.empty; + it.skip( + 'ensure monitors properly create and unpause connection pools when they discover servers', + { + metadata: { requires: { mongodb: '>=4.2.9', topology: '!load-balanced' } }, + test: async function () { + await client.connect(); + expect(events.shift()).to.equal(SERVER_HEARTBEAT_SUCCEEDED); + expect(events.shift()).to.equal(CONNECTION_POOL_READY); + + expect(events).to.be.empty; + + const heartBeatFailedEvent = once(client, SERVER_HEARTBEAT_FAILED); + await client.db('admin').command({ + configureFailPoint: 'failCommand', + mode: { times: 2 }, + data: { + failCommands: ['hello'], + errorCode: 1234, + appName: 'SDAMPoolManagementTest' + } + }); + await heartBeatFailedEvent; + expect(events.shift()).to.equal(SERVER_HEARTBEAT_FAILED); + expect(events.shift()).to.equal(CONNECTION_POOL_CLEARED); + + expect(events).to.be.empty; + + await once(client, SERVER_HEARTBEAT_SUCCEEDED); + expect(events.shift()).to.equal(SERVER_HEARTBEAT_SUCCEEDED); + expect(events.shift()).to.equal(CONNECTION_POOL_READY); + + expect(events).to.be.empty; + } } - }); + ).skipReason = 'TODO(NODE-5206): fix flaky test'; }); });