OHDSI / OHDSI/FeatureExtraction
Extract covariates with timeId's an those without in same call
Nobody has claimed this yet.
- Dominant language
- R
- Stars
- 74
- Forks
- 63
- PR merge metrics
- No merged PRs in 30d
Description
It would be nice to be able to extract covariates with timeIds (temporalCovariates, temporalSequenceCovariates, cohortBasedTemporalCovariate) with regular settings like created with createCovariateSettings.
For example:
library(FeatureExtraction)
phenoTypeDefs <- PhenotypeLibrary::getPlCohortDefinitionSet(1152:1215)
# create cohorts if don't exist
connectionDetails <- Eunomia::getEunomiaConnectionDetails()
Eunomia::createCohorts(connectionDetails)
CohortGenerator::createCohortTables(connectionDetails = connectionDetails,
cohortDatabaseSchema = "main",
cohortTableNames = CohortGenerator::getCohortTableNames("phenotypes"))
cohortGenerated <- CohortGenerator::generateCohortSet(
connectionDetails = connectionDetails,
cdmDatabaseSchema = "main",
cohortDatabaseSchema = "main",
cohortTableNames = CohortGenerator::getCohortTableNames("phenotypes"),
cohortDefinitionSet = phenoTypeDefs
)
covariateSettings <- list(
createCovariateSettings(
useDemographicsGender = TRUE,
useDemographicsAge = TRUE,
useCharlsonIndex = TRUE
),
createCohortBasedTemporalCovariateSettings(
analysisId = 49,
covariateCohortDatabaseSchema = "main",
covariateCohortTable = "phenotypes",
covariateCohorts = phenoTypeDefs
)
)
covariateData <- getDbCovariateData(
connectionDetails = connectionDetails,
cdmDatabaseSchema = "main",
cohortDatabaseSchema = "main",
cohortTable = "cohort",
cohortIds = 1,
rowIdField = "subject_id",
covariateSettings = covariateSettings
)
This currently fails with:
Error in dbAppendTable(conn, name, value) :
Column `timeId` does not exist in target table.
I think this would be much more flexible because you're not reliant on the non-temporal covariates being included in createTemporalCovariateSettings or createTemporalSequenceCovariateSettings. For example there is more stuff in createTemporalCovariateSettings than in the createTemporalSequenceCovariateSettings like Charlson index and Chads2. And of course there is none of that in the createCohortBasedTemporalCovariateSettings, not even demographics like age or gender.
For this to work you would need to add timeIds of NA for the non-temporal covSettings in the covariates table and same for startDay and endDay in analysisRef for the temporal stuff.
I think this should rather be in FeatureExtraction than in PatientLevelPrediction, but I had the following workaround implemented in PLP locally:
isTemporalList <- c()
if (inherits(covariateSettings, "list")) {
isTemporalList <- sapply(covariateSettings, function(x) {
isTemporal <- !is.null(x$temporal) && x$temporal
isTemporalSequence <- !is.null(x$temporalSequence) && x$temporalSequence
return(isTemporal || isTemporalSequence)
})
}
if (length(unique(isTemporalList)) > 1) {
ParallelLogger::logInfo("Mixed temporal and non-temporal covariates detected. Processing separately")
temporalSettingsList <- covariateSettings[isTemporalList]
staticSettingsList <- covariateSettings[!isTemporalList]
covariateData <- FeatureExtraction::getDbCovariateData(
connection = connection,
tempEmulationSchema = databaseDetails$tempEmulationSchema,
cdmDatabaseSchema = databaseDetails$cdmDatabaseSchema,
cdmVersion = databaseDetails$cdmVersion,
cohortTable = "#cohort_person",
cohortTableIsTemp = TRUE,
rowIdField = "row_id",
covariateSettings = temporalSettingsList
)
staticCovs <- FeatureExtraction::getDbCovariateData(
connection = connection,
tempEmulationSchema = databaseDetails$tempEmulationSchema,
cdmDatabaseSchema = databaseDetails$cdmDatabaseSchema,
cdmVersion = databaseDetails$cdmVersion,
cohortTable = "#cohort_person",
cohortTableIsTemp = TRUE,
rowIdField = "row_id",
covariateSettings = staticSettingsList
)
ParallelLogger::logInfo("Merging covariate data objects...")
staticCovs$covariates <- staticCovs$covariates %>%
dplyr::mutate(timeId = as.numeric(NA_real_))
covariateData$analysisRef <- covariateData$analysisRef %>%
dplyr::mutate(startDay = as.numeric(NA_real_),
endDay = as.numeric(NA_real_))
Andromeda::appendToTable(covariateData$covariates, staticCovs$covariates)
Andromeda::appendToTable(covariateData$covariateRef, staticCovs$covariateRef)
Andromeda::appendToTable(covariateData$analysisRef, staticCovs$analysisRef)
} else {
covariateData <- FeatureExtraction::getDbCovariateData(
connection = connection,
tempEmulationSchema = databaseDetails$tempEmulationSchema,
cdmDatabaseSchema = databaseDetails$cdmDatabaseSchema,
cdmVersion = databaseDetails$cdmVersion,
cohortTable = "#cohort_person",
cohortTableIsTemp = TRUE,
rowIdField = "row_id",
covariateSettings = covariateSettings
)
}
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start with the getDbCovariateData entry point and the covariates and analysisRef tables described in the issue. Reproduce the mixed temporal and non-temporal settings example, then trace how each result schema is created and combined. Done means one call accepts both setting types without the timeId, startDay, or endDay column errors.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- r
- Domain
- data, databases
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 35/100