diff --git a/extensions/notification/configManager/MongoConfigManager.js b/extensions/notification/configManager/MongoConfigManager.js
index ce26da086..1ea5c5d46 100644
--- a/extensions/notification/configManager/MongoConfigManager.js
+++ b/extensions/notification/configManager/MongoConfigManager.js
@@ -7,6 +7,7 @@ const LRUCache = require('arsenal').algorithms
 const { errors } = require('arsenal');
 
 const MongoClient = require('mongodb').MongoClient;
+const { promisify } = require('util');
 
 const ChangeStream = require('../../../lib/wrappers/ChangeStream');
 const { constructConnectionString, getMongoVersion } = require('../../utils/MongoUtils');
@@ -89,52 +90,36 @@ class MongoConfigManager extends BaseConfigManager {
         this._metastoreChangeStream = null;
     }
 
-    /**
+       /**
      * Connects to MongoDB using the MongoClientInterface
-     * and retreives the metastore collection
-     * @param {Function} cb callback
-     * @returns {undefined}
+     * and retrieves the metastore collection.
+     * @param {Function} cb - Callback function that takes an optional error argument.
+     * @returns {undefined} - This method does not return a value.
      */
-    _setupMongoClient(cb) {
+    async _setupMongoClient(cb) {
         const mongoUrl = constructConnectionString(this._mongoConfig);
         const client = new MongoClient(mongoUrl, {
             replicaSet: this._mongoConfig.replicaSet,
             useNewUrlParser: true,
-            readPreference: this._mongoConfig.readPreference,
         });
-
-        return client.connect().then(client => {
+        try {
+            await client.connect();
             this._logger.debug('Connected to MongoDB', {
                 method: 'MongoConfigManager._setupMongoClient',
             });
-            try {
-                this._mongoClient = client.db(this._mongoConfig.database, {
-                    ignoreUndefined: true,
-                });
-                this._metastore = this._mongoClient.collection(this._bucketMetastore);
-                // get mongodb version
-                getMongoVersion(this._mongoClient, (err, version) => {
-                    if (err) {
-                        this._logger.error('Could not get MongoDB version', {
-                            method: 'MongoConfigManager._setupMongoClient',
-                            error: err.message,
-                        });
-                        return cb(err);
-                    }
-                    this._mongoVersion = version;
-                    return cb();
-                });
-                return undefined;
-            } catch (error) {
-                return cb(error);
-            }
-        }).catch(err => {
+            this._mongoClient = client.db(this._mongoConfig.database, {
+                ignoreUndefined: true,
+            });
+            this._metastore = this._mongoClient.collection(this._bucketMetastore);
+            this._mongoVersion = await promisify(getMongoVersion)(this._mongoClient);
+            return cb();
+        } catch (err) {
             this._logger.error('Could not connect to MongoDB', {
                 method: 'MongoConfigManager._setupMongoClient',
                 error: err.message,
             });
             return cb(err);
-        });
+        }
     }
 
     /**
diff --git a/extensions/oplogPopulator/OplogPopulator.js b/extensions/oplogPopulator/OplogPopulator.js
index 43829ac8d..f359afa31 100644
--- a/extensions/oplogPopulator/OplogPopulator.js
+++ b/extensions/oplogPopulator/OplogPopulator.js
@@ -83,13 +83,12 @@ class OplogPopulator {
      */
     async _setupMongoClient() {
         try {
-            let client = new MongoClient(this._mongoUrl, {
+            const client  = await new MongoClient(this._mongoUrl, {
                 replicaSet: this._replicaSet,
                 useNewUrlParser: true,
                 useUnifiedTopology: true,
                 readPreference: this._mongoConfig.readPreference,
-            });
-            client = await client.connect();
+            }).connect();
             // connect to metadata DB
             this._mongoClient = client.db(this._database, {
                 ignoreUndefined: true,
diff --git a/lib/util/LocationStatusManager.js b/lib/util/LocationStatusManager.js
index 6c9787868..1705a18f2 100644
--- a/lib/util/LocationStatusManager.js
+++ b/lib/util/LocationStatusManager.js
@@ -173,7 +173,7 @@ class LocationStatusManager {
             this._locationStatusColl.insertOne({
                 _id: location,
                 value: locationConfig.getValue(),
-            }).finally(next);
+            }).then(() => next()).catch(next);
         }, err => {
             if (err) {
                 this._logger.error('Could not add new locations', {
diff --git a/tests/functional/ingestion/IngestionReader.js b/tests/functional/ingestion/IngestionReader.js
index 373959a19..f5b3f55de 100644
--- a/tests/functional/ingestion/IngestionReader.js
+++ b/tests/functional/ingestion/IngestionReader.js
@@ -4,6 +4,8 @@ const http = require('http');
 const kafka = require('node-rdkafka');
 const { MetadataMock, mockLogs } = require('../utils/MetadataMock');
 const MongoClient = require('mongodb').MongoClient;
+const { promisify } = require('util');
+const timers  = require('timers/promises');
 
 const dummyLogger = require('../../utils/DummyLogger');
 const dummyPensieveCredentials = require('./DummyPensieveCredentials.json');
@@ -113,21 +115,16 @@ describe('ingestion reader tests with mock', function fD() {
         await client.connect();
         db = client.db('metadata', { ignoreUndefined: true });
         try {
-            await new Promise((resolve, reject) => {
-                kafkaAdminClient.createTopic({
-                    topic,
-                    num_partitions: 1, // eslint-disable-line camelcase
-                    replication_factor: 1, // eslint-disable-line camelcase
-                }, err => {
-                    if (err && err.code === 36) {
-                        // if topic already exits.
-                        return resolve();
-                    }
-                    return err ? reject(err) : resolve();
-                });
+            const createTopic = promisify(kafkaAdminClient.createTopic).bind(kafkaAdminClient);
+            await createTopic({
+                topic,
+                num_partitions: 1, // eslint-disable-line camelcase
+                replication_factor: 1, // eslint-disable-line camelcase
             });
         } catch (err) {
-            throw err;
+            if (err.code !== 36) { // if topic does not already exist
+                throw err;
+            }
         }
         producer = new BackbeatProducer({
             kafka: testConfig.kafka,
@@ -140,7 +137,7 @@ describe('ingestion reader tests with mock', function fD() {
         });
 
         consumer.subscribe([testConfig.extensions.ingestion.topic]);
-        await new Promise(resolve => setTimeout(resolve, 2000));
+        await timers.setTimeout(2000);
         await db.createCollection('PENSIEVE');
         const collection = db.collection('PENSIEVE');
         await collection.insertOne(dummyPensieveCredentials);
@@ -154,28 +151,14 @@ describe('ingestion reader tests with mock', function fD() {
             zkClient.once('error', reject);
             zkClient.once('ready', resolve);
         });
-        await new Promise((resolve, reject) => {
-            initManagement(testConfig, err => {
-                if (err) {
-                    return reject(err);
-                }
-                return resolve();
-            });
-        });
+        await promisify(initManagement)(testConfig);
         const metadataMock = new MetadataMock();
         httpServer = http.createServer((req, res) => metadataMock.onRequest(req, res))
             .listen(testPort);
     });
 
     after(async () =>  {
-        await new Promise((resolve, reject) => {
-            httpServer.close(err => {
-                if (err) {
-                    return reject(err);
-                }
-                return resolve();
-            });
-        });
+        await promisify(httpServer.close);
         consumer.unsubscribe();
         await db.collection('PENSIEVE').drop();
         await client.close();
diff --git a/tests/unit/notification/configManager/MongoConfigManager.spec.js b/tests/unit/notification/configManager/MongoConfigManager.spec.js
index 3a95b5646..0a8559a69 100644
--- a/tests/unit/notification/configManager/MongoConfigManager.spec.js
+++ b/tests/unit/notification/configManager/MongoConfigManager.spec.js
@@ -150,7 +150,7 @@ describe('MongoConfigManager ::', () => {
             const getDbStub = sinon.stub().returns({
                 collection: getCollectionStub,
                 });
-            sinon.stub(MongoClient, 'connect').callsArgWith(2, null, {
+            sinon.stub(MongoClient.prototype, 'connect').resolves({
                 db: getDbStub,
             });
             manager._setupMongoClient(err => {