Loading DESCRIPTION +1 −1 Original line number Diff line number Diff line Package: ecospgr Title: Shared Loader Utilities for ecospg Version: 0.2.0 Version: 0.2.1 Authors@R: person("Lars", "Dalby", email = "lars@ecos.au.dk", role = c("aut", "cre")) Description: Extracts duplicated R code from ecospg data loaders into a Loading R/pipeline.R +4 −3 Original line number Diff line number Diff line Loading @@ -32,16 +32,17 @@ epg_run_pipeline <- function( set_latest = TRUE, on_conflict_version = "error" ) { ver_id <- NULL env <- environment() DBI::dbWithTransaction(con, { epg_ensure_topic(con, topic, description = topic_description) epg_ensure_dataset(con, topic, dataset) ver_id <<- epg_register_version( ver_id <- epg_register_version( con, topic, dataset, version_tag, on_conflict = on_conflict_version ) env$ver_id <- ver_id epg_set_raw_file_url(con, ver_id, raw_url) epg_persist_source_meta(con, ver_id, source_meta) Loading @@ -63,5 +64,5 @@ epg_run_pipeline <- function( ) }) invisible(ver_id) invisible(env$ver_id) } Loading
DESCRIPTION +1 −1 Original line number Diff line number Diff line Package: ecospgr Title: Shared Loader Utilities for ecospg Version: 0.2.0 Version: 0.2.1 Authors@R: person("Lars", "Dalby", email = "lars@ecos.au.dk", role = c("aut", "cre")) Description: Extracts duplicated R code from ecospg data loaders into a Loading
R/pipeline.R +4 −3 Original line number Diff line number Diff line Loading @@ -32,16 +32,17 @@ epg_run_pipeline <- function( set_latest = TRUE, on_conflict_version = "error" ) { ver_id <- NULL env <- environment() DBI::dbWithTransaction(con, { epg_ensure_topic(con, topic, description = topic_description) epg_ensure_dataset(con, topic, dataset) ver_id <<- epg_register_version( ver_id <- epg_register_version( con, topic, dataset, version_tag, on_conflict = on_conflict_version ) env$ver_id <- ver_id epg_set_raw_file_url(con, ver_id, raw_url) epg_persist_source_meta(con, ver_id, source_meta) Loading @@ -63,5 +64,5 @@ epg_run_pipeline <- function( ) }) invisible(ver_id) invisible(env$ver_id) }