Skip to content

Commit

Permalink
temp: turn off enqueueing to clear rogue queued item
Browse files Browse the repository at this point in the history
  • Loading branch information
cknight committed Sep 13, 2023
1 parent d4c7b27 commit a0c05a5
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions main.ts
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,10 @@ console.log("Starting main...");
const kv = await Deno.openKv();

async function enqueue(msg: number, delay: number): Promise<void> {
if (true) {
console.log("Temporarily disabling enqueueing of messages");
return;
}
const result = await kv.atomic()
.check({ key: LOCK_KEY, versionstamp: null }) //check no enqueue lock is present
.enqueue(msg, {
Expand Down

0 comments on commit a0c05a5

Please sign in to comment.