The hardware and bandwidth for this mirror is donated by METANET, the Webhosting and Full Service-Cloud Provider.
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[@]metanet.ch.
retry_tasks
argument with default
TRUE
(#170).nanonext
crew
promises in favor of native
event-driven promises in mirai
(#162).shiny.Rmd
and promises.Rmd
vignette to recommend native event-driven mirai
promises
(#162)..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.