diff --git a/pool/boltupgrades.go b/pool/boltupgrades.go index d56a1371..0ccf1eb7 100644 --- a/pool/boltupgrades.go +++ b/pool/boltupgrades.go @@ -637,11 +637,16 @@ func upgradeDB(db *BoltDB) error { return err } - if version >= BoltDBVersion { + if version == BoltDBVersion { // No upgrades necessary. return nil } + if version > BoltDBVersion { + // Database is too new. + return fmt.Errorf("expected database version <= %d, got %d", BoltDBVersion, version) + } + log.Infof("Upgrading database from version %d to %d", version, BoltDBVersion) return db.DB.Update(func(tx *bolt.Tx) error {