Skip to content

Commit

Permalink
Testing
Browse files Browse the repository at this point in the history
  • Loading branch information
arcshiftsolutions committed Nov 24, 2023
1 parent 663d088 commit 15bb4a0
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -139,8 +139,8 @@ public ResponseEntity<String> moveSchool(MoveSchoolData moveSchoolData) {
public OnboardingFileProcessResponse processOnboardingFile(OnboardingFileUpload fileUpload) {
List<SagaEntity> sagaEntities = this.edxFileOnboardingService.processOnboardingFile(Base64.getDecoder().decode(fileUpload.getFileContents()), fileUpload.getCreateUser());
log.info("Number of onboarded sagas stored is: " + sagaEntities.size());
// List<SagaEntity> 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<SagaEntity> 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;
Expand Down

0 comments on commit 15bb4a0

Please sign in to comment.