worker.on('failure', (queue, job, failure) => {
    logger('info', 'worker: job failure', `(${queue}) ${JSON.stringify(job)} -> ${failure}`);
  });