diff --git a/src/migrations/migration.data.ts b/src/migrations/migration.data.ts
index b2ce441822b0f252c58e7b8967c8556c6c532d05..740fb3adce43c3b493657c63a1cc0656277a9936 100644
--- a/src/migrations/migration.data.ts
+++ b/src/migrations/migration.data.ts
@@ -282,6 +282,12 @@ export const migrations: Migration[] = [
     docTypes: FLUIDPRICES_DOCTYPE,
     isCreate: true,
     run: async (_client: Client, docs: any[]): Promise<any> => {
+      if (docs.length > 0) {
+        console.log('collection already exists, delete all')
+        docs.forEach(async doc => {
+          await _client.destroy(doc)
+        })
+      }
       for (const fluidPrice of fluidsPricesData) {
         await _client.create(FLUIDPRICES_DOCTYPE, fluidPrice)
       }
diff --git a/src/migrations/migration.ts b/src/migrations/migration.ts
index 11acfabade7a54242e12b9764fd4343729eaf349..6dfe010f6526d38de1c8bfce281de623acb3f1d4 100644
--- a/src/migrations/migration.ts
+++ b/src/migrations/migration.ts
@@ -143,7 +143,7 @@ export async function migrate(
         migration.docTypes,
         migration.queryOptions
       )
-      if (docToUpdate.length) {
+      if (docToUpdate.length && !migration.isCreate) {
         const migratedDocs = await migration.run(_client, docToUpdate)
         if (migratedDocs.length) {
           result = await save(_client, migratedDocs)