fix: Ensure transaction commits before returning from listenQueue

csulit · Oct 30, 2024 · 8ae52aa · 8ae52aa
1 parent 162cdb0
commit 8ae52aa
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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...