@@ -118,7 +118,8 @@ public JobExecutionResource generateCohortViaJob(UserEntity userEntity, CohortDe
118
118
// as a lot of components are instantiated by the new operator
119
119
cohortDefinition .getDetails ().getExpression ();
120
120
121
- return runGenerateCohortJob (cohortDefinition , source , demographicStat ); }
121
+ return runGenerateCohortJob (cohortDefinition , source , demographicStat );
122
+ }
122
123
123
124
private Job buildGenerateCohortJob (CohortDefinition cohortDefinition , Source source , JobParameters jobParameters ) {
124
125
@@ -206,27 +207,19 @@ public Job buildJobForCohortGenerationWithDemographic(
206
207
return generateJobBuilder .build ();
207
208
}
208
209
209
- private JobExecutionResource runGenerateCohortJob (CohortDefinition cohortDefinition , Source source , Boolean retainCohortCovariates ) {
210
- final JobParametersBuilder jobParametersBuilder = getJobParametersBuilder (source , cohortDefinition , retainCohortCovariates );
211
- Job job = buildGenerateCohortJob (cohortDefinition , source , jobParametersBuilder .toJobParameters ());
212
- return jobService .runJob (job , jobParametersBuilder .toJobParameters ());
213
-
214
210
protected void addSessionParams (JobParametersBuilder builder , String sessionId ) {
215
211
builder .addString (TARGET_TABLE , GenerationUtils .getTempCohortTableName (sessionId ));
216
212
}
217
213
218
- private JobExecutionResource runGenerateCohortJob (CohortDefinition cohortDefinition , Source source ) {
219
- return runGenerateCohortJob (cohortDefinition , source , null );
220
- }
221
-
222
214
private JobExecutionResource runGenerateCohortJob (CohortDefinition cohortDefinition , Source source ,
223
215
Boolean demographic ) {
224
216
final JobParametersBuilder jobParametersBuilder = getJobParametersBuilder (source , cohortDefinition );
225
217
226
218
if (demographic != null && demographic ) {
227
219
jobParametersBuilder .addString (DEMOGRAPHIC_STATS , Boolean .TRUE .toString ());
228
220
Job job = buildJobForCohortGenerationWithDemographic (cohortDefinition , source , jobParametersBuilder );
229
- return jobService .runJob (job , jobParametersBuilder .toJobParameters ()); } else {
221
+ return jobService .runJob (job , jobParametersBuilder .toJobParameters ());
222
+ } else {
230
223
Job job = buildGenerateCohortJob (cohortDefinition , source , jobParametersBuilder .toJobParameters ());
231
224
return jobService .runJob (job , jobParametersBuilder .toJobParameters ());
232
225
}
0 commit comments