Refresh worker environment after update

.github/workflows/check-hipercow.yaml

@@ -30,6 +30,7 @@ jobs:
     env:
       GITHUB_PAT: ${{ secrets.GITHUB_TOKEN }}
       R_KEEP_PKG_SOURCE: yes
+      HIPERCOW_VIGNETTE_ROOT: ${{ env.RUNNER_TEMP }}/hipercow
 
     steps:
       - uses: actions/checkout@v3

.github/workflows/test-coverage.yaml

@@ -14,6 +14,7 @@ jobs:
     env:
       GITHUB_PAT: ${{ secrets.GITHUB_TOKEN }}
       CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
+      HIPERCOW_VIGNETTE_ROOT: ${{ env.RUNNER_TEMP }}/hipercow
 
     steps:
       - uses: actions/checkout@v3

DESCRIPTION

@@ -1,6 +1,6 @@
 Package: hipercow
 Title: High Performance Computing
-Version: 1.0.46
+Version: 1.0.47
 Authors@R: c(person("Rich", "FitzJohn", role = c("aut", "cre"),
                     email = "[email protected]"),
              person("Wes", "Hinsley", role = "aut"),

R/environment.R

@@ -98,6 +98,13 @@ hipercow_environment_create <- function(name = "default", packages = NULL,
     action <- if (exists) "Updated" else "Created"
     cli::cli_alert_success("{action} environment '{name}'")
   }
+
+  if (name == "rrq" && is_rrq_enabled(root)) {
+    cli::cli_alert_info("Refreshing existing rrq worker environments")
+    controller <- hipercow_rrq_controller(root)
+    ## or rrq::rrq_worker_refresh(controller) in recent rrq
+    rrq_message_send("REFRESH", controller = controller)
+  }
 }
 
 

R/rrq.R

@@ -224,3 +224,13 @@ hipercow_rrq_envir <- function(e) {
 hipercow_rrq_offload_path <- function(root) {
   offload_path <- file.path(root$path$rrq, "offload")
 }
+
+
+is_rrq_enabled <- function(root, call = parent.frame()) {
+  driver <- hipercow_driver_select(name = NULL, required = FALSE,
+                                   root = root, call = call)
+  if (!is.null(driver)) {
+    path_queue_id <- file.path(root$path$rrq, driver)
+    file.exists(path_queue_id)
+  }
+}

drivers/windows/DESCRIPTION

@@ -1,6 +1,6 @@
 Package: hipercow.windows
 Title: DIDE HPC Support for Windows
-Version: 1.0.46
+Version: 1.0.47
 Authors@R: c(person("Rich", "FitzJohn", role = c("aut", "cre"),
                     email = "[email protected]"),
              person("Wes", "Hinsley", role = "aut"),

vignettes/parallel.Rmd

@@ -9,6 +9,7 @@ vignette: >
 
 ```{r setup, include = FALSE}
 source("common.R")
+options(hipercow.timeout = 120)
 vignette_root <- new_hipercow_root_path()
 fs::file_copy("simulation.R", vignette_root)
 set_vignette_root(vignette_root)
@@ -18,11 +19,6 @@ cleanup <- withr::with_dir(
                                     new_directory = FALSE,
                                     initialise = FALSE))
 library(hipercow)
-
-```
-
-```{r, echo = FALSE, results = "asis"}
-add_header()
 ```
 
 # Task-level parallelism

vignettes/troubleshooting.Rmd

@@ -18,10 +18,6 @@ cleanup <- withr::with_dir(
                                     initialise = TRUE))
 ```
 
-```{r, echo = FALSE, results = "asis"}
-add_header()
-```
-
 ```{r}
 library(hipercow)
 ```