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.