module.exports = {
  name: "cleanup",
  scheduleSeconds: 30,
  async produceJobs(queue) {
    await queue.add("cleanup", { at: Date.now() }, {
      attempts: 2,
      backoff: { type: "fixed", delay: 1500 },
      removeOnComplete: 100,
      removeOnFail: 100
    });
  },
  async process(job, log) {
    log.info({ id: job.id }, "cleanup tick");
  }
};