Skip to content

Commit

Permalink
Added missing transactionManagers
Browse files Browse the repository at this point in the history
  • Loading branch information
spinsysmpeterson committed Dec 23, 2024
1 parent e39de7c commit 016943b
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -439,7 +439,7 @@ public JobExecutionResource generatePathways(final Integer pathwayAnalysisId, fi
);
TransactionalTasklet statisticsTasklet = new PathwayStatisticsTasklet(getSourceJdbcTemplate(source), getTransactionTemplate(), source, this, genericConversionService);
Step generateStatistics = stepBuilderFactory.get(GENERATE_PATHWAY_ANALYSIS + ".generateStatistics")
.tasklet(statisticsTasklet)
.tasklet(statisticsTasklet).transactionManager(getTransactionTemplate().getTransactionManager())
.build();

generateAnalysisJob.next(generateStatistics);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -147,15 +147,15 @@ Step userImportStep() {

UserImportTasklet userImportTasklet = new UserImportTasklet(transactionTemplate, userImportService);
return stepBuilderFactory.get("importUsers")
.tasklet(userImportTasklet)
.tasklet(userImportTasklet).transactionManager(transactionTemplate.getTransactionManager())
.build();
}

Job buildJobForUserImportTasklet(UserImportJob job) {

FindUsersToImportTasklet findUsersTasklet = new FindUsersToImportTasklet(transactionTemplate, userImportService);
Step findUsersStep = stepBuilderFactory.get("findUsersForImport")
.tasklet(findUsersTasklet)
.tasklet(findUsersTasklet).transactionManager(transactionTemplate.getTransactionManager())
.build();

if (job.getUserRoles() != null) {
Expand Down

0 comments on commit 016943b

Please sign in to comment.