Skip to content

Commit 599329a

Browse files
committed
Added an ack to the visibility timeout test
1 parent b43043a commit 599329a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

packages/redis-worker/src/queue.test.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -210,6 +210,10 @@ describe("SimpleQueue", () => {
210210
timestamp: expect.any(Date),
211211
})
212212
);
213+
214+
// Acknowledge the item and verify it's removed
215+
await queue.ack(second!.id);
216+
expect(await queue.size({ includeFuture: true })).toBe(0);
213217
} finally {
214218
await queue.close();
215219
}

0 commit comments

Comments
 (0)