ignore dropping error

Author: nbbeeken

test/integration/node-specific/examples/change_streams.test.js

@@ -60,7 +60,9 @@ maybeDescribe('examples(change-stream):', function () {
   it('Open A Change Stream', {
     metadata: { requires: { topology: ['replicaset'], mongodb: '>=3.6.0' } },
     test: async function () {
-      const looper = new Looper(() => db.collection('inventory').insertOne({ a: 1 }));
+      const looper = new Looper(async () => {
+        await db.collection('inventory').insertOne({ a: 1 });
+      });
       looper.run();
 
       // Start Changestream Example 1

test/integration/shared.js

@@ -99,8 +99,14 @@ async function setupDatabase(configuration, dbsToClean) {
   const client = configuration.newClient(configuration.writeConcernMax());
   try {
     for (const dbName of dbsToClean) {
-      await client.db(dbName).command({ dropAllUsersFromDatabase: 1, writeConcern: { w: 1 } });
-      await client.db(dbName).dropDatabase({ writeConcern: { w: 1 } });
+      await client
+        .db(dbName)
+        .command({ dropAllUsersFromDatabase: 1, writeConcern: { w: 'majority' } });
+      try {
+        await client.db(dbName).dropDatabase({ writeConcern: { w: 'majority' } });
+      } catch (error) {
+        if (!error.message.match(/database is currently being dropped/)) throw error;
+      }
     }
   } finally {
     await client.close();