mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-03 22:18:12 +08:00
Iron mq is being pendantic
This commit is contained in:
@@ -135,11 +135,12 @@ def test_ironmq():
|
|||||||
Conf.RETRY = 1
|
Conf.RETRY = 1
|
||||||
broker.enqueue('test')
|
broker.enqueue('test')
|
||||||
assert broker.dequeue() is not None
|
assert broker.dequeue() is not None
|
||||||
sleep(1.5)
|
sleep(3)
|
||||||
|
assert broker.dequeue() is not None
|
||||||
task = broker.dequeue()[0]
|
task = broker.dequeue()[0]
|
||||||
assert len(task) > 0
|
assert len(task) > 0
|
||||||
broker.acknowledge(task[0])
|
broker.acknowledge(task[0])
|
||||||
sleep(1.5)
|
sleep(3)
|
||||||
# delete job
|
# delete job
|
||||||
task_id = broker.enqueue('test')
|
task_id = broker.enqueue('test')
|
||||||
broker.delete(task_id)
|
broker.delete(task_id)
|
||||||
|
|||||||
Reference in New Issue
Block a user