diff --git a/packages/backend/src/api/repositories/LogRepository.ts b/packages/backend/src/api/repositories/LogRepository.ts
index 5d0d866e9..c7e2c00ca 100644
--- a/packages/backend/src/api/repositories/LogRepository.ts
+++ b/packages/backend/src/api/repositories/LogRepository.ts
@@ -163,9 +163,14 @@ export class LogRepository extends Repository<Log> {
       .innerJoin(IndividualEnrollment, 'individualEnrollment', '"individualEnrollment"."experimentId"=experiment.id')
       .innerJoin('experiment.queries', 'queries')
       .innerJoin('queries.metric', 'metric')
-      .innerJoin('metric.logs', 'logs', '"logs"."userId"="individualEnrollment"."userId"')
+      .innerJoin('metric.logs', 'logs')
       .where('experiment.id=:experimentId', { experimentId })
-      .execute();
+      .andWhere('"logs"."userId"="individualEnrollment"."userId"')
+      .getRawMany()
+      .catch((errorMsg: any) => {
+        const errorMsgString = repositoryError('LogRepository', 'getLogPerExperimentQuery', { experimentId }, errorMsg);
+        throw errorMsgString;
+      });
   }
 
   public prepareMetricString(metricId: string[]) {
diff --git a/packages/backend/src/api/services/AnalyticsService.ts b/packages/backend/src/api/services/AnalyticsService.ts
index 0659b130c..6742cf151 100644
--- a/packages/backend/src/api/services/AnalyticsService.ts
+++ b/packages/backend/src/api/services/AnalyticsService.ts
@@ -135,7 +135,7 @@ export class AnalyticsService {
       throw new HttpError(404, `Experiment not found for id: ${experimentId}`);
     }
 
-    this.sendExportData(experimentDetails, email, logger);
+    await this.sendExportData(experimentDetails, email, logger);
   }
 
   private async sendExportData(