Catch workspace issues in backfill upgrade commands

twentyhq · Dec 20, 2024 · 2ff79d0 · 2ff79d0
1 parent f1e38db
commit 2ff79d0
Show file tree

Hide file tree

Showing 2 changed files with 49 additions and 37 deletions.
diff --git a/...erver/src/database/commands/upgrade-version/0-40/0-40-record-position-backfill.command.ts b/...erver/src/database/commands/upgrade-version/0-40/0-40-record-position-backfill.command.ts
@@ -27,10 +27,16 @@ export class RecordPositionBackfillCommand extends ActiveWorkspacesCommandRunner
     workspaceIds: string[],
   ): Promise<void> {
     for (const workspaceId of workspaceIds) {
-      await this.recordPositionBackfillService.backfill(
-        workspaceId,
-        options.dryRun ?? false,
-      );
+      try {
+        await this.recordPositionBackfillService.backfill(
+          workspaceId,
+          options.dryRun ?? false,
+        );
+      } catch (error) {
+        this.logger.error(
+          `Error backfilling record position for workspace ${workspaceId}: ${error}`,
+        );
+      }
     }
   }
 }
diff --git a/...r/src/database/commands/upgrade-version/0-40/0-40-view-group-no-value-backfill.command.ts b/...r/src/database/commands/upgrade-version/0-40/0-40-view-group-no-value-backfill.command.ts
@@ -34,47 +34,53 @@ export class ViewGroupNoValueBackfillCommand extends ActiveWorkspacesCommandRunn
     workspaceIds: string[],
   ): Promise<void> {
     for (const workspaceId of workspaceIds) {
-      const viewRepository =
-        await this.twentyORMGlobalManager.getRepositoryForWorkspace<ViewWorkspaceEntity>(
-          workspaceId,
-          'view',
-        );
+      try {
+        const viewRepository =
+          await this.twentyORMGlobalManager.getRepositoryForWorkspace<ViewWorkspaceEntity>(
+            workspaceId,
+            'view',
+          );
 
-      const viewGroupRepository =
-        await this.twentyORMGlobalManager.getRepositoryForWorkspace<ViewGroupWorkspaceEntity>(
-          workspaceId,
-          'viewGroup',
-        );
+        const viewGroupRepository =
+          await this.twentyORMGlobalManager.getRepositoryForWorkspace<ViewGroupWorkspaceEntity>(
+            workspaceId,
+            'viewGroup',
+          );
 
-      const views = await viewRepository.find({
-        relations: ['viewGroups'],
-      });
+        const views = await viewRepository.find({
+          relations: ['viewGroups'],
+        });
 
-      for (const view of views) {
-        if (view.viewGroups.length === 0) {
-          continue;
-        }
+        for (const view of views) {
+          if (view.viewGroups.length === 0) {
+            continue;
+          }
 
-        // We're assuming for now that all viewGroups belonging to the same view have the same fieldMetadataId
-        const viewGroup = view.viewGroups?.[0];
-        const fieldMetadataId = viewGroup?.fieldMetadataId;
+          // We're assuming for now that all viewGroups belonging to the same view have the same fieldMetadataId
+          const viewGroup = view.viewGroups?.[0];
+          const fieldMetadataId = viewGroup?.fieldMetadataId;
 
-        if (!fieldMetadataId || !viewGroup) {
-          continue;
-        }
+          if (!fieldMetadataId || !viewGroup) {
+            continue;
+          }
 
-        const fieldMetadata = await this.fieldMetadataRepository.findOne({
-          where: { id: viewGroup.fieldMetadataId },
-        });
+          const fieldMetadata = await this.fieldMetadataRepository.findOne({
+            where: { id: viewGroup.fieldMetadataId },
+          });
 
-        if (!fieldMetadata) {
-          continue;
-        }
+          if (!fieldMetadata) {
+            continue;
+          }
 
-        await this.fieldMetadataRelatedRecordsService.syncNoValueViewGroup(
-          fieldMetadata,
-          view,
-          viewGroupRepository,
+          await this.fieldMetadataRelatedRecordsService.syncNoValueViewGroup(
+            fieldMetadata,
+            view,
+            viewGroupRepository,
+          );
+        }
+      } catch (error) {
+        this.logger.error(
+          `Error backfilling view group no value for workspace ${workspaceId}: ${error}`,
         );
       }
     }