Fixed flaky integration test: test_publish_requeue_consume() (#2048)

celery · Jul 1, 2024 · 35a5f0a · 35a5f0a
1 parent 5218099
commit 35a5f0a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/t/integration/common.py b/t/integration/common.py
@@ -410,6 +410,8 @@ def callback(body, message):
                     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)