diff --git a/config/deno-kv.ts b/config/deno-kv.ts index 2e9b4ec..0f226fb 100644 --- a/config/deno-kv.ts +++ b/config/deno-kv.ts @@ -449,7 +449,8 @@ export async function listenQueue(kv: Deno.Kv) { WHERE id = $1 `, }); - continue; + if (transaction) await transaction.commit(); + return; } // from here...