diff --git a/src/mappings/marketplace/events/bid_placed.ts b/src/mappings/marketplace/events/bid_placed.ts
index 69d91efe2..c629fb184 100644
--- a/src/mappings/marketplace/events/bid_placed.ts
+++ b/src/mappings/marketplace/events/bid_placed.ts
@@ -107,7 +107,7 @@ export async function bidPlaced(
         }
     }
 
-    Promise.all([ctx.store.save(bid), ctx.store.save(listing)])
+    await Promise.all([ctx.store.save(bid), ctx.store.save(listing)])
 
     if (!skipSave) syncCollectionStats(listing.makeAssetId.collection.id)
 
diff --git a/src/mappings/marketplace/events/listing_cancelled.ts b/src/mappings/marketplace/events/listing_cancelled.ts
index aa3ee11b5..8ff26bce8 100644
--- a/src/mappings/marketplace/events/listing_cancelled.ts
+++ b/src/mappings/marketplace/events/listing_cancelled.ts
@@ -92,7 +92,7 @@ export async function listingCancelled(
         ctx.store.save(listing.makeAssetId)
     }
 
-    Promise.all([ctx.store.insert(ListingStatus, listingStatus as any), ctx.store.save(listing)])
+    await Promise.all([ctx.store.insert(ListingStatus, listingStatus as any), ctx.store.save(listing)])
 
     if (!skipSave) syncCollectionStats(listing.makeAssetId.collection.id)
 
diff --git a/src/mappings/marketplace/events/listing_created.ts b/src/mappings/marketplace/events/listing_created.ts
index 4158b7b91..171a63260 100644
--- a/src/mappings/marketplace/events/listing_created.ts
+++ b/src/mappings/marketplace/events/listing_created.ts
@@ -130,7 +130,7 @@ export async function listingCreated(
     }
     makeAssetId.recentListing = listing
 
-    Promise.all([
+    await Promise.all([
         ctx.store.insert(Listing, listing as any),
         ctx.store.insert(ListingStatus, listingStatus as any),
         ctx.store.save(makeAssetId),
diff --git a/src/mappings/marketplace/events/listing_filled.ts b/src/mappings/marketplace/events/listing_filled.ts
index db8b28762..655238db1 100644
--- a/src/mappings/marketplace/events/listing_filled.ts
+++ b/src/mappings/marketplace/events/listing_filled.ts
@@ -98,7 +98,7 @@ export async function listingFilled(
             height: block.height,
             createdAt: new Date(block.timestamp),
         })
-        ctx.store.insert(ListingStatus, listingStatus as any)
+        await ctx.store.insert(ListingStatus, listingStatus as any)
     }
 
     const sale = new ListingSale({
@@ -120,7 +120,7 @@ export async function listingFilled(
         ctx.store.save(listing.makeAssetId)
     }
 
-    Promise.all([ctx.store.save(listing), ctx.store.save(sale)])
+    await Promise.all([ctx.store.save(listing), ctx.store.save(sale)])
 
     if (!skipSave) syncCollectionStats(listing.makeAssetId.collection.id)