diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/SaasMigrationService.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/SaasMigrationService.java
index 0b4335c44..cb023ab9a 100644
--- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/SaasMigrationService.java
+++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/SaasMigrationService.java
@@ -16,6 +16,8 @@ import com.iqser.red.service.redaction.v1.model.MigrationRequest;
 import com.iqser.red.storage.commons.exception.StorageException;
 import com.iqser.red.storage.commons.exception.StorageObjectDoesNotExist;
 import com.iqser.red.storage.commons.service.StorageService;
+import com.knecon.fforesight.databasetenantcommons.providers.TenantSyncService;
+import com.knecon.fforesight.databasetenantcommons.providers.events.TenantSyncEvent;
 import com.knecon.fforesight.tenantcommons.TenantContext;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -30,7 +32,7 @@ import static com.knecon.fforesight.service.layoutparser.internal.api.queue.Layo
 @Slf4j
 @Service
 @RequiredArgsConstructor
-public class SaasMigrationService {
+public class SaasMigrationService implements TenantSyncService {
 
     private final AutomaticAnalysisJob automaticAnalysisJob;
     private final FileStatusPersistenceService fileStatusPersistenceService;
@@ -45,6 +47,13 @@ public class SaasMigrationService {
 
     private final SaasAnnotationIdMigrationService saasAnnotationIdMigrationService;
 
+
+    @Override
+    public void syncTenant(TenantSyncEvent tenantSyncEvent) {
+
+        startMigrationForTenant(tenantSyncEvent.getTenantId());
+    }
+
     // Persistence-Service needs to be scaled to 1.
 
     public void startMigrationForTenant(String tenantId) {
@@ -138,4 +147,6 @@ public class SaasMigrationService {
     }
 
 
+
+
 }