diff --git a/dev/articles/work-queue.html b/dev/articles/work-queue.html index 9c4e685d..0b8ea0da 100644 --- a/dev/articles/work-queue.html +++ b/dev/articles/work-queue.html @@ -303,7 +303,7 @@

Implementing our workerrs <- dbSendQuery(con, "SELECT * FROM sqroot_vignette_example ORDER BY in_val") dbFetch(rs) #> in_val out_val -#> 1 7 2.645751 +#> 1 7 NA #> 2 8 2.828427 #> 3 9 3.000000 dbClearResult(rs) ; rs <- NULL @@ -321,11 +321,11 @@

Implementing our worker writeLines(outputs[[1]]) #> Not sqroot-ing as another worker got there first -writeLines(outputs[[2]]) -#> Sqroot-ing 7 ... #> Sqroot-ing 8 ... #> Sqroot-ing 9 ... -#> Shutting down. +#> Shutting down. +writeLines(outputs[[2]]) +#> Sqroot-ing 7 ...

Notice that the work has been shared between the 2 workers. If these 2 weren’t enough, we could happily add more to keep the system going.

diff --git a/dev/pkgdown.yml b/dev/pkgdown.yml index 62100361..f5fe7451 100644 --- a/dev/pkgdown.yml +++ b/dev/pkgdown.yml @@ -3,7 +3,7 @@ pkgdown: 2.0.7.9000 pkgdown_sha: 13d8d621105a3a527a05e46c6c805a6564c39791 articles: work-queue: work-queue.html -last_built: 2023-12-20T09:02Z +last_built: 2023-12-20T13:28Z urls: reference: https://rpostgres.r-dbi.org/reference article: https://rpostgres.r-dbi.org/articles