Start a Redis worker process loop — worker • future.redis

The worker process blocks for tasks on the specified queue (a Redis list). The worker continues to process tasks from the queue untile the queue liveness key is removed (see removeQ()), the number of processed tasks reaches the iter limit, or until a Redis communication or other error occurs; after which the worker exits (quits R).

worker(
  queue = getOption("future.redis.queue", "{{session}}"),
  linger = 10,
  config = redis_config(),
  iter = Inf,
  quit = FALSE,
  log = nullfile()
)

Arguments

queue: Redis task queue name.
linger: in seconds, max time before system checks (including termination).
config: A redux::redis_config Redis configuration object.
iter: Maximum number of tasks to acquire before exiting.
quit: if TRUE, quit R on exit.
log: divert stdout and messages to log file.

Value

After conclusion of the worker loop, either R exits or NULL is silently returned.