workerShutdown: Worker operations

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

Description

Worker operations

Usage

workerShutdown(workername, url = getFlowerURL())

workerPoolRestart(workername, url = getFlowerURL())

workerPoolGrow(workername, n = 1, url = getFlowerURL())

workerPoolShrink(workername, n = 1, url = getFlowerURL())

workerPoolAutoscale(workername, min, max, url = getFlowerURL())

workerQueueAddConsumer(workername, queue, url = getFlowerURL())

workerQueueCancelConsumer(workername, queue, url = getFlowerURL())

Arguments

workername	Character: filter info by worker's name
url	Character: Flower URL
n	Integer: number of pool processes to grow/shrink
min	Integer: minimum number of pool processes
max	Integer: maximum number of pool processes
queue	Character: queue name

Value

Flower response

Examples

worker <- names(workerList())[[1]]
workerShutdown(worker)
workerPoolRestart(worker)
workerPoolGrow(worker, 4)
workerPoolShrink(worker, 4)
workerPoolAutoscale(worker, 4)
workerQueueAddConsumer(worker, "sample-queue")
workerQueueCancelConsumer(worker, "sample-queue")

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