diff --git a/internal/database/postgres.go b/internal/database/postgres.go
index 837f59c..89afbeb 100644
--- a/internal/database/postgres.go
+++ b/internal/database/postgres.go
@@ -51,15 +51,16 @@ func (db *DB) migratePostgres() error {
 	var version int
 	err = tx.QueryRow(`SELECT version FROM schema_migrations`).Scan(&version)
 	if err != nil && !errors.Is(err, sql.ErrNoRows) {
-		return errors.Wrap(err, "no rows")
+		return errors.Wrap(err, "failed to query schema version")
 	}
 
 	if version == len(postgresMigrations) {
 		return nil
+	} else if version > len(postgresMigrations) {
+		return errors.New("autobrr (version %d) older than schema (version: %d)", len(postgresMigrations), version)
 	}
-	if version > len(postgresMigrations) {
-		return errors.New("old")
-	}
+
+	db.log.Info().Msgf("Beginning database schema upgrade from version %v to version: %v", version, len(postgresMigrations))
 
 	if version == 0 {
 		if _, err := tx.Exec(postgresSchema); err != nil {
@@ -67,6 +68,7 @@ func (db *DB) migratePostgres() error {
 		}
 	} else {
 		for i := version; i < len(postgresMigrations); i++ {
+			db.log.Info().Msgf("Upgrading Database schema to version: %v", i)
 			if _, err := tx.Exec(postgresMigrations[i]); err != nil {
 				return errors.Wrap(err, "failed to execute migration #%v", i)
 			}
diff --git a/internal/database/sqlite.go b/internal/database/sqlite.go
index 80f29bb..bd16f87 100644
--- a/internal/database/sqlite.go
+++ b/internal/database/sqlite.go
@@ -65,6 +65,8 @@ func (db *DB) migrateSQLite() error {
 		return errors.New("autobrr (version %d) older than schema (version: %d)", len(sqliteMigrations), version)
 	}
 
+	db.log.Info().Msgf("Beginning database schema upgrade from version %v to version: %v", version, len(sqliteMigrations))
+
 	tx, err := db.handler.Begin()
 	if err != nil {
 		return err
@@ -77,6 +79,7 @@ func (db *DB) migrateSQLite() error {
 		}
 	} else {
 		for i := version; i < len(sqliteMigrations); i++ {
+			db.log.Info().Msgf("Upgrading Database schema to version: %v", i)
 			if _, err := tx.Exec(sqliteMigrations[i]); err != nil {
 				return errors.Wrap(err, "failed to execute migration #%v", i)
 			}