Skip to content

Commit

Permalink
req nanonext 0.10.0
Browse files Browse the repository at this point in the history
  • Loading branch information
shikokuchuo committed Sep 2, 2023
1 parent 3f32524 commit 3eb4f2d
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
4 changes: 2 additions & 2 deletions DESCRIPTION
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
Package: mirai
Type: Package
Title: Minimalist Async Evaluation Framework for R
Version: 0.9.1.9017
Version: 0.9.1.9018
Description: Lightweight parallel code execution and distributed computing.
Designed for simplicity, a 'mirai' evaluates an R expression asynchronously,
on local or network resources, resolving automatically upon completion.
Expand All @@ -23,5 +23,5 @@ Encoding: UTF-8
Depends:
R (>= 3.5)
Imports:
nanonext (>= 0.9.2)
nanonext (>= 0.10.0)
RoxygenNote: 7.2.3
6 changes: 3 additions & 3 deletions NEWS.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# mirai 0.9.1.9017 (development)
# mirai 0.9.1.9018 (development)

* Previously deprecated function `server()` is removed in favour of `daemon()`.
* Dispatcher enhancements and fixes:
Expand All @@ -15,8 +15,8 @@
* Improved shell quoting of daemon launch commands makes it easier to deploy manually via `launch_remote()`.
* The class `miraiInterrupt` has been retired and interrupts now generate a `miraiError` with an empty value.
* Certain error messages are more accurate and informative.
* General performance improvements through updates in nanonext v[0.9.2].
* Requires nanonext >= [0.9.2] and R >= 3.5.
* General performance improvements through updates in nanonext 0.10.0.
* Requires nanonext >= 0.10.0 and R >= 3.5.

# mirai 0.9.1

Expand Down
4 changes: 2 additions & 2 deletions R/mirai.R
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ daemon <- function(url, asyncdial = FALSE, maxtasks = Inf, idletime = Inf,
if (cleanup %% 2L) rm(list = names(.GlobalEnv), envir = .GlobalEnv)
if (clr & as.raw(2L)) lapply((new <- search())[!new %in% se], detach, unload = TRUE, character.only = TRUE)
if (clr & as.raw(4L)) options(op)
if (cleanup >= 8L) gc(verbose = FALSE)
if (clr & as.raw(8L)) gc(verbose = FALSE)
if (count < timerstart) start <- mclock()
count <- count + 1L

Expand Down Expand Up @@ -847,7 +847,7 @@ saisei <- function(i, force = FALSE, .compute = "default") {
envir <- ..[[.compute]]
i <- as.integer(`length<-`(i, 1L))
length(envir[["sockc"]]) && i > 0L && i <= envir[["n"]] && substr(envir[["urls"]][[i]], 1L, 1L) != "t" || return()
r <- query_dispatcher(sock = envir[["sockc"]], command = if (force) -i else i, mode = 2L)
r <- query_dispatcher(sock = envir[["sockc"]], command = if (force) -i else i, mode = 9L)
is.character(r) && nzchar(r) || return()
envir[["urls"]][[i]] <- r
r
Expand Down

0 comments on commit 3eb4f2d

Please sign in to comment.