diff --git a/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go b/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go index 46ac7116..b2aa9dcc 100644 --- a/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go +++ b/roomserver/storage/postgres/deltas/20210416150927_state_blocks_refactor.go @@ -138,13 +138,6 @@ func UpStateBlocksRefactor(tx *sql.Tx) error { } newblocks = append(newblocks, blocknid) - _, err = tx.Exec(` - DELETE FROM roomserver_state_block WHERE state_block_nid=$1 - `, block) - if err != nil { - return fmt.Errorf("tx.Exec (delete old block): %w", err) - } - if snapshot != lastsnapshot { var newsnapshot types.StateSnapshotNID err = tx.QueryRow(`