@Panel.register
def active_queues(panel):
 return [dict(queue.as_dict(recurse=True)) for queue in panel.consumer.task_consumer.queues]

@ Panel . register def active_queues ( panel ) : return [ dict ( queue . as_dict ( recurse = True ) ) for queue in panel . consumer . task_consumer . queues ]
list the task queues a worker are currently consuming from .