diff --git a/config/deno-kv.ts b/config/deno-kv.ts index 664e984..af04994 100644 --- a/config/deno-kv.ts +++ b/config/deno-kv.ts @@ -363,7 +363,7 @@ export async function listenQueue(kv: Deno.Kv) { }); if (listingByUrl.rowCount && listingByUrl.rowCount > 0) { - console.info("Listing already exists"); + console.info("Listing query by url already exists"); const updateListingResult = await transaction.queryObject({ args: [ @@ -439,7 +439,9 @@ export async function listenQueue(kv: Deno.Kv) { }); if (listingByTitle.rowCount && listingByTitle.rowCount > 0) { - continue; + await transaction.commit() + console.log("Listing query by title already exists") + return; } let property;