Launches a P2P worker and adds it to a P2P cluster — worker • future.p2p

Launches a P2P worker and adds it to a P2P cluster

Usage

worker(
  cluster = p2p_cluster_name(host = host, ssh_args = ssh_args),
  host = "pipe.pico.sh",
  ssh_args = NULL,
  duration = 60 * 60
)

Arguments

cluster: The p2p cluster to contribute to.
host: (character string) The hostname serving the pico service.
ssh_args: (character vector) Optional SSH arguments.
duration: Duration (in seconds) to offer working on futures.

Sequential, single-core processing by default

A P2P worker runs sequentially (plan(sequential)) and is configured to with a single CPU core to prevent nested parallelization.

Examples

if (FALSE) { # interactive()
## Start a P2P cluster worker
future.p2p::worker()
}