Skip to main content

active_queues

List the task queues a worker is currently consuming from.

def active_queues(
state: object
) - > list

List the task queues a worker is currently consuming from.

Parameters

NameTypeDescription
stateobjectThe current worker state object containing the consumer and task consumer information.

Returns

TypeDescription
listA list of dictionaries representing the active task queues, where each dictionary contains the queue configuration details.