The hardware and bandwidth for this mirror is donated by dogado GmbH, the Webhosting and Full Service-Cloud Provider. Check out our Wordpress Tutorial.
If you wish to report a bug, or if you are interested in having us mirror your free-software or open-source project, please feel free to contact us at mirror[@]dogado.de.
.args
rather than ...
in mirai::mirai()
to make sure arguments continue to be passed as local variables in mirai
>= 0.13.1.9012.autoscale()
, descale()
, and started()
to facilitate different kinds of Shiny apps.scale
and throttle
methods of controller$promise()
. promise()
now always calls autoscale()
to make sure one and only one auto-scaling loop is running asynchronously. Auto-scaling thus continues even after the promise resolves.error
argument to collect()
(#166).crew
promises and Shiny extended tasks (#157, @jcheng5).controller$promise(mode = "one")
in the vignette on promises (@jcheng5).error
argument in pop()
which may help with integration with ExtendedTask
(@jcheng5).nanonext
>= 0.12.0 and mirai
>= 0.12.0.push_backlog()
and pop_backlog()
to manage cases when it is not desirable to push to saturated controllers (https://github.com/ropensci/targets/issues/1220).mirai
object of a task pushed to the controller. This allows users to interact with the task directly, e.g. to create a promise object with promises::as.promise()
(#146, @jcheng5).walk()
method for controllers and controller groups to submit tasks in batch and return control immediately without waiting for any task to complete (#148, @jcheng5).collect()
method for popping multiple tasks at once (#148, @jcheng5).nonempty()
, resolved()
, unresolved()
, and unpopped()
to help with #148.mirai
dispatcher error message extremely verbose.crew_terminate_signal()
.crew_monitor_local()
to help users monitor and terminate local R processes created by crew
and mirai
.crew_terminate_process()
to terminate a process manually without resorting to SIGKILL
on Windows.controller$map()
if at least one task threw one. warnings = FALSE
suppresses this behavior.output = TRUE
in daemon()
so stdout
and stderr
streams print.local_log_directory
and local_log_join
to write to local log files.asyncdial
to autoexit
.Sys.info()[["user"]]
to get the user in crew_clean()
(#135, @luwidmer).controller$map()
can no longer be used if there are tasks waiting to be popped.cli
progress bar in map()
.R6
members in the private
list and add active bindings where interfaces are necessary (#137). Ad hoc tests that absolutely need to modify private objects can use object$.__enclos_env__$private
trick, but these tests should be skipped on CRAN in case there is a change to R6
that breaks this..signal
from mirai::mirai()
since all mirai
tasks signal as of mirai
version 0.11.2.9025.crew_throttle()
, a decoupled mechanism for throttling that can be applied to scaling.throttle
argument, powered by crew_throttle()
.mirai::status()
again in daemons_info()
and make it configurable using seconds_interval
and seconds_timeout
in both the client and the launcher (#128).seconds_exit
because exitlinger
in mirai
is now obsolete (#125, @shikokuchuo).mirai::nextget("cv")
to count unresolved tasks instead of looping through all the task objects (#131).collect()
in auto-scaling. Simplifies much of the code. Made possible by the efficiency gains in #131.wait()
.seconds_interval
in map()
no longer defaults to controller$client$seconds_interval
.launcher$terminate_workers()
terminates one or more workers, and launcher$terminate
terminates the whole launcher.processes
field to set the number of local mirai
daemons for asynchronous requests to launch and terminate the serious workers. Then, launch_worker()
and terminate_worker()
can optionally make use of launcher$async$eval()
to send these asynchronous calls.mirai
0.9.1 (#96).status()
retries (@shikokuchuo, #100).launch_max
to error out if workers repeatedly launch without completing any tasks (#101, @shikokuchuo, @multimeric).launcher$done()
.algorithm
argument to the push()
, shove()
, and map()
methods of controllers and controller groups, as well as arguments/fields in crew_eval()
and its return value (#113, @shikokuchuo).mirai::nextstream()
(#115, @shikokuchuo).crew_tls()
function for TLS configuration (#120).tls_enable
and tls_config
arguments of crew_client()
etc. in favor of a tls
argument which accepts crew_tls()
objects (#120).nanonext
and mirai
.map()
method to the controller class for functional programming (#93).scale()
which launched too many workers when active - demand
was less than 0.crew_clean()
to help clean up any lingering dispatchers and workers from previous sessions.targets
1.1.3.daemons()
in daemons_info()
.nanonext
0.9.0.R6
schedule class (#84).launch_worker()
(#84). Unfortunately neither of these changes is back-compatible for third-party launcher plugins. However, the controller interface is still back-compatible, so targets
remains unaffected.NULL
result in pop()$result[[1L]]
.assigned
and complete
stats from mirai
0.8.7.9029.pkgdown
reference and Rd
families to clarify which parts are for end-users and which parts are for launcher plugin developers.controller$shove()
and schedule$list()
to support fast extensions for functional programming.mirai
0.9.0 or greater.packageStartupMessage()
..args
instead of ...
in mirai::mirai()
.set.seed()
instead of withr::local_seed()
(#67, @shikokuchuo).rlang::duplicate()
(#72, @shikokuchuo).saturated()
controller method to support targets
.worker_index
column to controller summaries.auto_scale
argument/field of controllers in favor of the scale
argument of push()
, pop()
, and wait()
.self$router$seconds_interval
(#76).clean()
and instead terminate lost workers on launch.collect
argument to pop()
.asyncdial
from call to mirai::daemons()
.clean()
controller method.scale()
and launch()
controller methods.inactive()
launcher method to help with the above.nanonext::.unresolved()
(#49).callr
launcher to the local process launcher (#56).mirai
implements the dispatcher another way (#60).substitute
argument to push()
(#63).mirai
(#61).processx
instead of callr
for the local process launcher (#64").crew_eval()
by e.g. relying on nanonext::mclock()
for the time.empty()
method to check if the controller or controller group is empty.mirai
for globals cleanup, garbage collection, and global option resets (#65).mirai
(#65).pop()
.crew_wait()
to crew_retry()
.crew_assert()
and crew_random_name()
to help launcher plugins.listen()
method to start()
in the router class.poll()
method now retries mirai::daemons()
for robustness.crew_retry()
gains a max_tries
argument.router$daemons
to NULL
in poll()
when the connection has a momentary problem.listening()
.call()
method to make it easier to write custom launcher plugins.as.character()
to make sure the list
argument supplied to rm()
is safe. Fixes a test that was failing on R-devel with crew
version 0.0.4.seconds_poll_high
and seconds_poll_low
fields and arguments for compatibility with mirai
development and release versions.async_dial
field in the router for compatibility with mirai
development and release versions.These binaries (installable software) and packages are in development.
They may not be fully stable and should be used with caution. We make no claims about them.
Health stats visible at Monitor.