From fc51619557771fe6e9176b1474ade866f8727eb4 Mon Sep 17 00:00:00 2001 From: Jeff Thompson <160783290+jthompson-arcus@users.noreply.github.com> Date: Fri, 22 Mar 2024 13:13:28 -0400 Subject: [PATCH] Set a busy handler for `dbUpdate()` and `dbSelect()` --- R/utils_get_db.R | 1 + R/utils_insert_db.R | 1 + 2 files changed, 2 insertions(+) diff --git a/R/utils_get_db.R b/R/utils_get_db.R index 2a49f3aa4..08d117381 100644 --- a/R/utils_get_db.R +++ b/R/utils_get_db.R @@ -18,6 +18,7 @@ dbSelect <- function(query, db_name = golem::get_golem_options('assessment_db_na errFlag <- FALSE con <- DBI::dbConnect(RSQLite::SQLite(), db_name) + RSQLite::sqliteSetBusyHandler(con, 3000) tryCatch( expr = { rs <- DBI::dbSendQuery(con, glue::glue_sql(query, .envir = .envir, .con = con)) diff --git a/R/utils_insert_db.R b/R/utils_insert_db.R index 72e629fc2..0542ea615 100644 --- a/R/utils_insert_db.R +++ b/R/utils_insert_db.R @@ -21,6 +21,7 @@ dbUpdate <- function(command, db_name = golem::get_golem_options('assessment_db_ errFlag <- FALSE con <- DBI::dbConnect(RSQLite::SQLite(), db_name) + RSQLite::sqliteSetBusyHandler(con, 3000) tryCatch({ rs <- DBI::dbSendStatement(con, glue::glue_sql(command, .envir = .envir, .con = con)) if (!is.null(params))