diff --git a/userapi/storage/postgres/deltas/2022110411000000_server_names.go b/userapi/storage/postgres/deltas/2022110411000000_server_names.go index 12d34b50c..cdf266a15 100644 --- a/userapi/storage/postgres/deltas/2022110411000000_server_names.go +++ b/userapi/storage/postgres/deltas/2022110411000000_server_names.go @@ -45,11 +45,6 @@ func UpServerNames(ctx context.Context, tx *sql.Tx, serverName gomatrixserverlib return fmt.Errorf("add server name to %q error: %w", table, err) } } - // Commit at this point, because it's possible that altering indices will - // fail and force us to roll back. - if err := tx.Commit(); err != nil { - return fmt.Errorf("can't commit after column addition: %w", err) - } for newTable, oldTable := range serverNamesDropPK { q := fmt.Sprintf( "ALTER TABLE IF EXISTS %s DROP CONSTRAINT IF EXISTS %s;",