diff --git a/src/main/java/org/ohdsi/webapi/cohortcharacterization/GenerateCohortCharacterizationTasklet.java b/src/main/java/org/ohdsi/webapi/cohortcharacterization/GenerateCohortCharacterizationTasklet.java index 0a9186121..9450f1276 100644 --- a/src/main/java/org/ohdsi/webapi/cohortcharacterization/GenerateCohortCharacterizationTasklet.java +++ b/src/main/java/org/ohdsi/webapi/cohortcharacterization/GenerateCohortCharacterizationTasklet.java @@ -74,7 +74,7 @@ protected String[] prepareQueries(ChunkContext chunkContext, CancelableJdbcTempl saveInfoWithinTheSeparateTransaction(jobId, serializedDesign, userEntity); final Integer sourceId = Integer.valueOf(jobParams.get(SOURCE_ID).toString()); final Source source = sourceService.findBySourceId(sourceId); - final String cohortTable = jobParams.get(TARGET_TABLE).toString(); + final String cohortTable = String.format("%s.%s", SourceUtils.getTempQualifier(source), jobParams.get(TARGET_TABLE).toString()); final String sessionId = jobParams.get(SESSION_ID).toString(); final String tempSchema = SourceUtils.getTempQualifier(source); boolean includeAnnual = cohortCharacterization.getCcFeatureAnalyses().stream()