diff --git a/backend/src/handler/tila/vuorovaikutusKierrosTilaManager.ts b/backend/src/handler/tila/vuorovaikutusKierrosTilaManager.ts
index 056dd5fe1..a9a923f3e 100644
--- a/backend/src/handler/tila/vuorovaikutusKierrosTilaManager.ts
+++ b/backend/src/handler/tila/vuorovaikutusKierrosTilaManager.ts
@@ -92,13 +92,13 @@ class VuorovaikutusKierrosTilaManager extends TilaManager<VuorovaikutusKierros,
     }
 
     const kielitiedot: Kielitiedot = projekti.kielitiedot;
-    const pdfEnsisijainen = await this.generatePDFsForLanguage(kielitiedot.ensisijainenKieli, julkaisu, projekti);
+    const { kutsuPDFPath } = await this.generatePDFsForLanguage(kielitiedot.ensisijainenKieli, julkaisu, projekti);
     julkaisu.vuorovaikutusPDFt = {};
-    julkaisu.vuorovaikutusPDFt[kielitiedot.ensisijainenKieli] = pdfEnsisijainen;
+    julkaisu.vuorovaikutusPDFt[kielitiedot.ensisijainenKieli] = { kutsuPDFPath };
 
     if (kielitiedot.toissijainenKieli) {
-      const pdfToissijainen = await this.generatePDFsForLanguage(kielitiedot.toissijainenKieli, julkaisu, projekti);
-      julkaisu.vuorovaikutusPDFt[kielitiedot.toissijainenKieli] = pdfToissijainen;
+      const { kutsuPDFPath: pdfToissijainen } = await this.generatePDFsForLanguage(kielitiedot.toissijainenKieli, julkaisu, projekti);
+      julkaisu.vuorovaikutusPDFt[kielitiedot.toissijainenKieli] = { kutsuPDFPath: pdfToissijainen };
     }
   }
 
@@ -114,7 +114,11 @@ class VuorovaikutusKierrosTilaManager extends TilaManager<VuorovaikutusKierros,
     attachments.push(asiakirjaEmailService.createPDFAttachment(pdfEnsisijainen));
 
     if (kielitiedot.toissijainenKieli) {
-      julkaisu.vuorovaikutusPDFt[kielitiedot.toissijainenKieli] = await this.generatePDFsForLanguage(kielitiedot.toissijainenKieli, julkaisu, projekti);
+      julkaisu.vuorovaikutusPDFt[kielitiedot.toissijainenKieli] = await this.generatePDFsForLanguage(
+        kielitiedot.toissijainenKieli,
+        julkaisu,
+        projekti
+      );
       attachments.push(asiakirjaEmailService.createPDFAttachment(pdfEnsisijainen));
     }
     await projektiDatabase.vuorovaikutusKierrosJulkaisut.insert(projekti.oid, julkaisu);
diff --git a/backend/src/projektiSearch/dynamoDBStreamHandler.ts b/backend/src/projektiSearch/dynamoDBStreamHandler.ts
index 99eff1aad..24ee6c498 100644
--- a/backend/src/projektiSearch/dynamoDBStreamHandler.ts
+++ b/backend/src/projektiSearch/dynamoDBStreamHandler.ts
@@ -7,6 +7,7 @@ import { setupLambdaMonitoring, setupLambdaMonitoringMetaData, wrapXRayAsync } f
 import { MaintenanceEvent, ProjektiSearchMaintenanceService } from "./projektiSearchMaintenanceService";
 import { invokeLambda } from "../aws/lambda";
 import { Context } from "aws-lambda";
+import { migrateFromOldSchema } from "../database/schemaUpgrade";
 
 const parse = DynamoDB.Converter.unmarshall;
 
@@ -14,7 +15,8 @@ async function handleUpdate(record: DynamoDBRecord) {
   if (record.dynamodb?.NewImage) {
     const projekti = parse(record.dynamodb.NewImage) as DBProjekti;
     log.info(`${record.eventName}`, { oid: projekti.oid });
-    await projektiSearchService.indexProjekti(projekti);
+
+    await projektiSearchService.indexProjekti(migrateFromOldSchema(projekti));
   } else {
     log.error("No DynamoDB record to update");
   }