Function errorPayload

__tests__/core/queue.ts:376–389

(id: number)

    describe("failed job managment", () => {
      beforeEach(async () => {
        const errorPayload = function (id: number) {
          return JSON.stringify({
            worker: "busted-worker-" + id,
            queue: "busted-queue",
            payload: {
              class: "busted_job",
              queue: "busted-queue",
              args: [1, 2, 3],
            },
            exception: "ERROR_NAME",
            error: "I broke",
            failed_at: new Date().toString(),
          });
        };

        await queue.connection.redis.rpush(
          queue.connection.key("failed"),