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