taskAbort: Task operations

In nuno-agostinho/floweRy: Celery task queue manager via Flower's REST API

Description

Task operations

Usage

taskAbort(id, url = getFlowerURL())

taskRevoke(id, terminate = TRUE, signal = "SIGTERM", url = getFlowerURL())

taskTimeout(
  workername,
  task,
  softLimit = 30,
  hardLimit = 100,
  url = getFlowerURL()
)

taskRateLimit(workername, task, ratelimit, url = getFlowerURL())

Arguments

id	Character: task identifier
url	Character: Flower URL
terminate	Boolean: terminate task if running?
signal	Character: signal to send when terminating task
workername	Character: worker name
softLimit	Integer: soft limit
hardLimit	Integer: hard limit
ratelimit	Integer: rate limit

Value

Flower response

Examples

task <- rownames(taskList())[[1]]
taskAbort(task)
taskRevoke(task)
worker <- names(workerList())[[1]]
taskTimeout(worker, "tasks.add", softLimit=60)
taskRateLimit(worker, "tasks.add", 200)

nuno-agostinho/floweRy documentation built on Dec. 22, 2021, 3:19 a.m.