crew_controller_group: Create a controller group.

In wlandau/crew: A Distributed Worker Launcher Framework

Create a controller group.

Description

Create an R6 object to submit tasks and launch workers through multiple crew controllers.

Usage

crew_controller_group(..., seconds_interval = 1)

Arguments

...	R6 controller objects or lists of R6 controller objects. Nested lists are allowed, but each element must be a control object or another list.
seconds_interval	Number of seconds between polling intervals waiting for certain internal synchronous operations to complete, such as checking mirai::status()

See Also

Other controller_group: crew_class_controller_group

Examples

if (identical(Sys.getenv("CREW_EXAMPLES"), "true")) {
persistent <- crew_controller_local(name = "persistent")
transient <- crew_controller_local(
  name = "transient",
  tasks_max = 1L
)
group <- crew_controller_group(persistent, transient)
group$start()
group$push(name = "task", command = sqrt(4), controller = "transient")
group$wait()
group$pop()
group$terminate()
}

wlandau/crew documentation built on Feb. 8, 2025, 10:12 a.m.