diff --git a/magnetico-migrator.go b/magnetico-migrator.go
index 424983a..ef93ac1 100644
--- a/magnetico-migrator.go
+++ b/magnetico-migrator.go
@@ -73,6 +73,8 @@ func mergeDatabases(pyDb *sql.DB, goDb persistence.Database) error {
 		chunk, err := old.GetTorrentsChunk(pyDb, lastId, *chunkSize)
 		if err != nil {
 			zap.L().Error("Error while getting torrents chunk", zap.Uint64("last-id", lastId))
+
+			return err
 		}
 
 		if len(chunk) == 0 {