diff --git a/config/deno-kv.ts b/config/deno-kv.ts
index 604f3b1..3bec40a 100644
--- a/config/deno-kv.ts
+++ b/config/deno-kv.ts
@@ -496,10 +496,12 @@ export async function listenQueue(kv: Deno.Kv) {
 
               // Update all processed properties in transaction
               for (const prop of processedProperty) {
+                await transaction.begin();
                 await transaction.queryObject({
                   args: [prop.ai_generated_description, prop.id],
                   text: `UPDATE Property SET ai_generated_description = $1 WHERE id = $2`,
                 });
+                await transaction.commit();
               }
             }