fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-06 17:18:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Pause on dequeue for sqs

Browse Source
This commit is contained in:
ilan
2017-04-05 12:56:40 +03:00
parent 6bfb4f8013
commit 1983a523fc
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_brokers.py
+1
View File
@@ -189,6 +189,7 @@ def test_sqs(monkeypatch):
# Retry test # Retry test
monkeypatch.setattr(Conf, 'RETRY', 1) monkeypatch.setattr(Conf, 'RETRY', 1)
broker.enqueue('test') broker.enqueue('test')
sleep(2)
assert broker.dequeue() is not None assert broker.dequeue() is not None
sleep(2) sleep(2)
task = broker.dequeue()[0] task = broker.dequeue()[0]