from amqplib import client_0_8 as amqp
conn = amqp.Connection(host='localhost:5672 ', userid='guest', password=
    'guest', virtual_host='/', insist=False)
chan = conn.channel()
name, jobs, consumers = chan.queue_declare(queue='queue_name', passive=True)
Получить список задач в очереди в Celery