From fe84fb2fdcb355ad2e63c83d09add0b8ef9f1bc2 Mon Sep 17 00:00:00 2001
From: Johan Haals <johan.haals@gmail.com>
Date: Mon, 3 May 2021 14:14:57 +0200
Subject: [PATCH] Await transactions

Signed-off-by: Johan Haals <johan.haals@gmail.com>
---
 .../src/next/DefaultCatalogProcessingEngine.ts                | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/plugins/catalog-backend/src/next/DefaultCatalogProcessingEngine.ts b/plugins/catalog-backend/src/next/DefaultCatalogProcessingEngine.ts
index c8c49e4bd9..6bee54f153 100644
--- a/plugins/catalog-backend/src/next/DefaultCatalogProcessingEngine.ts
+++ b/plugins/catalog-backend/src/next/DefaultCatalogProcessingEngine.ts
@@ -37,7 +37,7 @@ class Connection implements EntityProviderConnection {
   async applyMutation(mutation: EntityProviderMutation): Promise<void> {
     const db = this.config.processingDatabase;
     if (mutation.type === 'full') {
-      db.transaction(async tx => {
+      await db.transaction(async tx => {
         await db.replaceUnprocessedEntities(tx, {
           sourceKey: this.config.id,
           type: 'full',
@@ -46,7 +46,7 @@ class Connection implements EntityProviderConnection {
       });
       return;
     }
-    db.transaction(async tx => {
+    await db.transaction(async tx => {
       await db.replaceUnprocessedEntities(tx, {
         sourceKey: this.config.id,
         type: 'delta',