fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-07 23:58:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

tests: sqs is not atomic

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-10 11:34:35 +02:00
parent 0b9df26218
commit 5195464c31
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_brokers.py
+3 -4
View File
@@ -184,8 +184,9 @@ def test_sqs():
assert broker.dequeue() is None assert broker.dequeue() is None
# fail # fail
broker.enqueue('test') broker.enqueue('test')
task_id = broker.dequeue()[0] while task is None:
broker.fail(task_id) task = broker.dequeue()
broker.fail(task[0])
# bulk test # bulk test
for i in range(10): for i in range(10):
broker.enqueue('test') broker.enqueue('test')
@@ -196,9 +197,7 @@ def test_sqs():
broker.acknowledge(task[0]) broker.acknowledge(task[0])
# delete queue # delete queue
broker.enqueue('test') broker.enqueue('test')
broker.enqueue('test')
broker.purge_queue() broker.purge_queue()
assert broker.dequeue() is None
broker.delete_queue() broker.delete_queue()
# back to django-redis # back to django-redis
Conf.SQS = None Conf.SQS = None