Это нужно для того, чтобы сбрасывать state в начале тестов
Сейчас делаю так:
- queue.tube[qname]:tube_release_all_tasks()
- queue.tube[qname]:drop()
Но этого видимо недостаточно ?
Вероятно нужно метод queue.tube.tube_name:release_all()
Обсуждают сегодня