Fix schema_evolution version (#142)

criteo · Aug 8, 2017 · 15a407d · 15a407d
1 parent 2c9e8ea
commit 15a407d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/com/criteo/cuttle/Database.scala b/core/src/main/scala/com/criteo/cuttle/Database.scala
@@ -96,7 +96,7 @@ private[cuttle] object Database {
         SELECT MAX(schema_version) FROM schema_evolutions
       """.query[Option[Int]].unique.map(_.getOrElse(0))
 
-      _ <- schemaEvolutions.map(_.update).drop(currentSchemaVersion).zipWithIndex.foldLeft(NoUpdate) {
+      _ <- schemaEvolutions.map(_.update).zipWithIndex.drop(currentSchemaVersion).foldLeft(NoUpdate) {
         case (evolutions, (evolution, i)) =>
           evolutions *> evolution.run *> sql"""
             INSERT INTO schema_evolutions (schema_version, schema_update)