Develop

.github/workflows/odbc-cdmc-spark.yaml

@@ -91,7 +91,8 @@ jobs:
               httpPath = Sys.getenv("HTTP_PATH"),
               workspace = Sys.getenv("WORKSPACE"),
               uid = Sys.getenv("USER"),
-              pwd = Sys.getenv("PASSWORD")            
+              pwd = Sys.getenv("PASSWORD"),
+              useNativeQuery = FALSE
             ),
             file = "./args.rds"
           )

R/CDMInterface.R

@@ -111,7 +111,9 @@ fetchCohortTable <- function(cdm, cohorts, cohortTableName, andromeda, andromeda
     }
   }
 
-  cdm <- CDMConnector::dropSourceTable(cdm = cdm, name = "tp_temp_tbl")
+  if ("tp_temp_tbl" %in% CDMConnector::listSourceTables(cdm)) {
+    cdm <- CDMConnector::dropSourceTable(cdm = cdm, name = "tp_temp_tbl")
+  }
 
   andromeda[[andromedaTableName]] <- andromeda[[andromedaTableName]] %>%
     dplyr::mutate(r = dplyr::row_number()) %>%