From 15bb4a0623ddb07bd2484b73e23a8bce2740debb Mon Sep 17 00:00:00 2001 From: Marco Villeneuve Date: Thu, 23 Nov 2023 17:15:56 -0800 Subject: [PATCH] Testing --- .../bc/gov/educ/api/edx/controller/v1/EdxSagaController.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/api/src/main/java/ca/bc/gov/educ/api/edx/controller/v1/EdxSagaController.java b/api/src/main/java/ca/bc/gov/educ/api/edx/controller/v1/EdxSagaController.java index fee14518..f0ebc55b 100644 --- a/api/src/main/java/ca/bc/gov/educ/api/edx/controller/v1/EdxSagaController.java +++ b/api/src/main/java/ca/bc/gov/educ/api/edx/controller/v1/EdxSagaController.java @@ -139,8 +139,8 @@ public ResponseEntity moveSchool(MoveSchoolData moveSchoolData) { public OnboardingFileProcessResponse processOnboardingFile(OnboardingFileUpload fileUpload) { List sagaEntities = this.edxFileOnboardingService.processOnboardingFile(Base64.getDecoder().decode(fileUpload.getFileContents()), fileUpload.getCreateUser()); log.info("Number of onboarded sagas stored is: " + sagaEntities.size()); -// List first100Sagas = sagaEntities.stream().limit(100).toList(); -// first100Sagas.forEach(sagaEntity -> startServicesSaga(sagaEntity.getSagaName().equals(ONBOARD_SCHOOL_USER_SAGA.toString()) ? ONBOARD_SCHOOL_USER_SAGA : ONBOARD_DISTRICT_USER_SAGA, sagaEntity)); + List first100Sagas = sagaEntities.stream().limit(100).toList(); + first100Sagas.forEach(sagaEntity -> startServicesSaga(sagaEntity.getSagaName().equals(ONBOARD_SCHOOL_USER_SAGA.toString()) ? ONBOARD_SCHOOL_USER_SAGA : ONBOARD_DISTRICT_USER_SAGA, sagaEntity)); OnboardingFileProcessResponse response = new OnboardingFileProcessResponse(); response.setProcessedCount(Integer.toString(sagaEntities.size())); return response;