A Redis-based future task queue implementation — RedisFuture • future.redis

Set up the future parameters.

RedisFuture(
  expr = NULL,
  substitute = TRUE,
  envir = parent.frame(),
  globals = TRUE,
  packages = NULL,
  lazy = FALSE,
  queue = getOption("future.redis.queue", "{{session}}"),
  config = redis_config(),
  output_queue = NA_character_,
  max_retries = 3L,
  ...
)

Arguments

expr: An R expression.
substitute: If TRUE, argument expr is substitute():ed, otherwise not.
envir: The environment from where global objects should be identified.
globals: (optional) a logical, a character vector, or a named list to control how globals are handled. For details, see section 'Globals used by future expressions' in the help for future().
packages: (optional) a character vector specifying packages to be attached in the R environment evaluating the future.
lazy: If FALSE (default), the future is resolved eagerly (starting immediately), otherwise not.
queue: A Redis key name of the task queue, or a RedisWorkerConfiguration object as returned by startLocalWorkers().
config: A redux::redis_config Redis configuration object.
output_queue: (optional) Redis key name of the work output queue (note: reserved for future use).
max_retries: Maximum number of times the future can be re-submitted to the task queue in the event of failure.
...: Additional named elements of the future.

Value

An object of class RedisFuture.