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

queue size is not atomic on ironmq

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-08 16:22:38 +02:00
parent 52f353fb37
commit 69df45ea4e
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_brokers.py
+4 -5
View File
@@ -107,18 +107,17 @@ def test_ironmq():
broker.enqueue('test') broker.enqueue('test')
# clear before we start # clear before we start
broker.purge_queue() broker.purge_queue()
assert broker.queue_size() == 0
# enqueue # enqueue
broker.enqueue('test') broker.enqueue('test')
assert broker.queue_size() == 1
# dequeue # dequeue
task = broker.dequeue() task = broker.dequeue()
assert task[1] == 'test' assert task[1] == 'test'
broker.acknowledge(task[0]) broker.acknowledge(task[0])
assert broker.queue_size() == 0 assert broker.dequeue() is None
# Retry test # Retry test
Conf.RETRY = 1 Conf.RETRY = 1
broker.enqueue('test') broker.enqueue('test')
assert broker.queue_size() == 1
assert broker.dequeue() is not None assert broker.dequeue() is not None
sleep(1.5) sleep(1.5)
task = broker.dequeue() task = broker.dequeue()
@@ -128,7 +127,7 @@ def test_ironmq():
# delete job # delete job
task_id = broker.enqueue('test') task_id = broker.enqueue('test')
broker.delete(task_id) broker.delete(task_id)
assert broker.queue_size() == 0 assert broker.dequeue() is None
# fail # fail
task_id = broker.enqueue('test') task_id = broker.enqueue('test')
broker.fail(task_id) broker.fail(task_id)
@@ -144,7 +143,7 @@ def test_ironmq():
broker.enqueue('test') broker.enqueue('test')
broker.enqueue('test') broker.enqueue('test')
broker.purge_queue() broker.purge_queue()
assert broker.queue_size() == 0 assert broker.dequeue() is None
broker.delete_queue() broker.delete_queue()
# back to django-redis # back to django-redis
Conf.IRON_MQ = None Conf.IRON_MQ = None