[timeseries] DROP timeseries_state PK if it exists (#454)

As some previous migration feature might left one, causing rare crashes where a backfill collide with normal state updates
criteo · Sep 2, 2019 · 0c4a2a3 · 0c4a2a3
1 parent ca60cc2
commit 0c4a2a3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/timeseries/src/main/scala/com/criteo/cuttle/timeseries/Database.scala b/timeseries/src/main/scala/com/criteo/cuttle/timeseries/Database.scala
@@ -86,7 +86,8 @@ private[timeseries] object Database {
       CREATE INDEX timeseries_backfills_by_status ON timeseries_backfills (status);
     """.update.run,
     contextIdMigration,
-    NoUpdate // We removed this migration, so we reserve this slot
+    NoUpdate, // We removed this migration, so we reserve this slot
+    sql"DROP INDEX IF EXISTS `PRIMARY` ON timeseries_state".update.run
   )
 
   val doSchemaUpdates: ConnectionIO[Unit] = utils.updateSchema("timeseries", schema)