Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

This commit is contained in:
Tomer Nosrati 2024-07-01 18:25:31 +03:00 committed by GitHub
parent 5218099cb1
commit 35a5f0a6cf
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
t/integration/common.py
View File

@ -410,6 +410,8 @@ class BasePriority:
serializer='pickle', serializer='pickle',
priority=prio_max priority=prio_max
) )
# Sleep to make sure that queue sorted based on priority
sleep(0.5)
with consumer: with consumer:
conn.drain_events(timeout=1) conn.drain_events(timeout=1)