diff --git a/core/server/services/members/importer/importer.js b/core/server/services/members/importer/importer.js
index 21058e4883..50644d5ffd 100644
--- a/core/server/services/members/importer/importer.js
+++ b/core/server/services/members/importer/importer.js
@@ -8,7 +8,6 @@ const tpl = require('@tryghost/tpl');
 const urlUtils = require('../../../../shared/url-utils');
 const db = require('../../../data/db');
 const emailTemplate = require('./email-template');
-const jobsService = require('../../jobs');
 
 const messages = {
     filenameCollision: 'Filename already exists, please try again.',
@@ -22,14 +21,16 @@ module.exports = class MembersCSVImporter {
      * @param {Object} settingsCache - An instance of the Ghost Settings Cache
      * @param {Object} ghostMailer - An instance of GhostMailer
      * @param {(string) => boolean} isSet - Method checking if specific feature is enabled
+     * @param {({name, at, job, data, offloaded}) => void} addJob - Method registering an async job
      * @param {() => Object} getMembersApi
      */
-    constructor(config, settingsCache, getMembersApi, ghostMailer, isSet) {
+    constructor(config, settingsCache, getMembersApi, ghostMailer, isSet, addJob) {
         this._storagePath = config.storagePath;
         this._settingsCache = settingsCache;
         this._getMembersApi = getMembersApi;
         this._ghostMailer = ghostMailer;
         this._isSet = isSet;
+        this._addJob = addJob;
     }
 
     /**
@@ -280,7 +281,7 @@ module.exports = class MembersCSVImporter {
             };
         } else {
             const emailRecipient = user.email;
-            jobsService.addJob({
+            this._addJob({
                 job: async () => {
                     const result = await this.perform(job.id);
                     const importLabelModel = result.imported ? await LabelModel.findOne(importLabel) : null;
diff --git a/core/server/services/members/service.js b/core/server/services/members/service.js
index 0b31527d53..32f947eaea 100644
--- a/core/server/services/members/service.js
+++ b/core/server/services/members/service.js
@@ -15,6 +15,7 @@ const config = require('../../../shared/config');
 const ghostVersion = require('@tryghost/version');
 const _ = require('lodash');
 const {GhostMailer} = require('../mail');
+const jobsService = require('../jobs');
 
 const messages = {
     noLiveKeysInDevelopment: 'Cannot use live stripe keys in development. Please restart in production mode.',
@@ -132,7 +133,8 @@ const membersService = {
     settingsCache,
     () => membersApi,
     ghostMailer,
-    labsService.isSet
+    labsService.isSet,
+    jobsService.addJob
     ),
 
     stats: new MembersStats({