diff --git a/main/java/org/gcube/portal/databook/server/MigrationStarter.java b/main/java/org/gcube/portal/databook/server/MigrationStarter.java
index 1180c5a..16b86c9 100644
--- a/main/java/org/gcube/portal/databook/server/MigrationStarter.java
+++ b/main/java/org/gcube/portal/databook/server/MigrationStarter.java
@@ -848,7 +848,7 @@ closeSession(session_dest);
             for (Row row: rows){
                 boolean flag = false;
                 while (!flag) {
-                    session_dest.execute(getWriteStatementNotification(session_dest, row)).wasApplied();
+                    flag = session_dest.execute(getWriteStatementNotification(session_dest, row)).wasApplied();
                 }
             }
         }catch (Exception e){
@@ -917,7 +917,7 @@ closeSession(session_dest);
                     for (Row row: rows){
                         boolean flag = false;
                         while (!flag) {
-                            session_dest.execute(getWriteStatementPost(session_dest, row)).wasApplied();
+                            flag = session_dest.execute(getWriteStatementPost(session_dest, row)).wasApplied();
                         }
                     }
                 }catch (Exception e){