diff --git a/roomserver/storage/shared/storage.go b/roomserver/storage/shared/storage.go
index f84844b38..45020d551 100644
--- a/roomserver/storage/shared/storage.go
+++ b/roomserver/storage/shared/storage.go
@@ -571,12 +571,10 @@ func (d *Database) handleRedactions(
 			return nil, "", nil
 		}
 
-		err = d.Writer.Do(d.DB, txn, func(txn *sql.Tx) error {
-			return d.RedactionsTable.InsertRedaction(ctx, txn, tables.RedactionInfo{
-				Validated:        false,
-				RedactionEventID: event.EventID(),
-				RedactsEventID:   event.Redacts(),
-			})
+		err = d.RedactionsTable.InsertRedaction(ctx, txn, tables.RedactionInfo{
+			Validated:        false,
+			RedactionEventID: event.EventID(),
+			RedactsEventID:   event.Redacts(),
 		})
 		if err != nil {
 			return nil, "", err
@@ -605,9 +603,7 @@ func (d *Database) handleRedactions(
 		redactedEvent.Event = redactedEvent.Redact()
 	}
 	// overwrite the eventJSON table
-	err = d.Writer.Do(d.DB, txn, func(txn *sql.Tx) error {
-		return d.EventJSONTable.InsertEventJSON(ctx, txn, redactedEvent.EventNID, redactedEvent.JSON())
-	})
+	err = d.EventJSONTable.InsertEventJSON(ctx, txn, redactedEvent.EventNID, redactedEvent.JSON())
 	if err != nil {
 		return nil, "", err
 	}