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)