From 35a5f0a6cf895f632cc6a4bb8f396504858bd3a2 Mon Sep 17 00:00:00 2001 From: Tomer Nosrati Date: Mon, 1 Jul 2024 18:25:31 +0300 Subject: [PATCH] Fixed flaky integration test: test_publish_requeue_consume() (#2048) --- t/integration/common.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/t/integration/common.py b/t/integration/common.py index ed61b3a2..a6412936 100644 --- a/t/integration/common.py +++ b/t/integration/common.py @@ -410,6 +410,8 @@ class BasePriority: serializer='pickle', priority=prio_max ) + # Sleep to make sure that queue sorted based on priority + sleep(0.5) with consumer: conn.drain_events(timeout=1)