refactor(config): Ensure transaction wraps property updates in deno-kv

csulit · Oct 25, 2024 · 7f6e850 · 7f6e850
1 parent deb8dc8
commit 7f6e850
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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();
               }
             }