def active_queues(state):
    """Return information about the queues a worker consumes from."""
    return [dict(queue.as_dict(recurse=True))
            for queue in state.consumer.task_consumer.queues]