diff --git a/ghost/core/core/server/services/members/service.js b/ghost/core/core/server/services/members/service.js index dfc7a3cac7..4eb3abc784 100644 --- a/ghost/core/core/server/services/members/service.js +++ b/ghost/core/core/server/services/members/service.js @@ -148,7 +148,16 @@ module.exports = { } })(); - await stripeService.migrations.execute(); + const membersMigrationJobName = 'members-migrations'; + if (!(await jobsService.hasExecuted(membersMigrationJobName))) { + jobsService.addOneOffJob({ + name: membersMigrationJobName, + offloaded: false, + job: stripeService.migrations.execute.bind(stripeService.migrations) + }); + + await jobsService.awaitCompletion(membersMigrationJobName); + } }, contentGating: require('./content-gating'),