diff --git a/relayapi/storage/shared/storage.go b/relayapi/storage/shared/storage.go
index 04045ae92..468c3b861 100644
--- a/relayapi/storage/shared/storage.go
+++ b/relayapi/storage/shared/storage.go
@@ -88,6 +88,7 @@ func (d *Database) CleanAsyncTransactions(
 	for i, receipt := range receipts {
 		nids[i] = receipt.GetNID()
 	}
+
 	err := d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
 		err := d.RelayQueue.DeleteQueueEntries(ctx, txn, userID.Domain(), nids)
 		return err
@@ -96,6 +97,14 @@ func (d *Database) CleanAsyncTransactions(
 		return fmt.Errorf("d.deleteQueueEntries: %w", err)
 	}
 
+	err = d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
+		err := d.RelayQueueJSON.DeleteQueueJSON(ctx, txn, nids)
+		return err
+	})
+	if err != nil {
+		return fmt.Errorf("d.deleteQueueJSON: %w", err)
+	}
+
 	return nil
 }