def delete_queue(*queues):
    k = Kuyruk()
    with k.connection() as conn:
        for name in queues:
            logger.debug("deleting queue %s", name)
            with conn.channel() as ch:
                ch.queue_delete(queue=name)
Delete queues from RabbitMQ
dataset/ETHPy150Open cenk/kuyruk/tests/integration/util.py/delete_queue