Skip to content
Snippets Groups Projects

Jobs crash

Merged Andrei Cioromila requested to merge jobs-crash into develop
8 files
+ 13
12
Compare changes
  • Side-by-side
  • Inline
Files
8
 
const { last, get, chain, difference } = require('lodash')
 
const Promise = require('bluebird')
const config = require('config')
const config = require('config')
const {
const {
@@ -12,8 +14,6 @@ const {
@@ -12,8 +14,6 @@ const {
const Job = require('pubsweet-component-jobs')
const Job = require('pubsweet-component-jobs')
const { last, get, chain, difference } = require('lodash')
const s3Config = get(config, 'pubsweet-component-aws-s3', {})
const s3Config = get(config, 'pubsweet-component-aws-s3', {})
const notifications = require('./emails/notifications')
const notifications = require('./emails/notifications')
@@ -134,10 +134,12 @@ module.exports = models => async (req, res) => {
@@ -134,10 +134,12 @@ module.exports = models => async (req, res) => {
})),
})),
]
]
fragment.invitations.forEach(inv => {
await Promise.each(fragment.invitations, async inv =>
Job.cancelQueue(`removal-${inv.userId}-${inv.id}`)
Promise.all([
Job.cancelQueue(`reminders-${inv.userId}-${inv.id}`)
Job.cancelQueue(`removal-${inv.userId}-${inv.id}`),
})
Job.cancelQueue(`reminders-${inv.userId}-${inv.id}`),
 
]),
 
)
fragment.invitations = []
fragment.invitations = []
fragment.recommendations = []
fragment.recommendations = []