Account for test queue not being there

alephdata · Jun 28, 2024 · c1f95c5 · c1f95c5
1 parent cc0cde5
commit c1f95c5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/tests/test_taskqueue.py b/tests/test_taskqueue.py
@@ -187,6 +187,8 @@ def did_nack():
 def test_get_priority_bucket():
     redis = get_fakeredis()
     rmq_channel = get_rabbitmq_channel()
+    rmq_channel.queue_delete("index")
+    declare_rabbitmq_queue(rmq_channel, "index")
     flush_queues(rmq_channel, redis, ["index"])
     collection_id = 1