mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-08 01:18:12 +08:00
Disque now passes the double ack test
This commit is contained in:
@@ -86,12 +86,7 @@ def test_disque():
|
|||||||
assert task is not None
|
assert task is not None
|
||||||
broker.acknowledge(task[0])
|
broker.acknowledge(task[0])
|
||||||
# test duplicate acknowledge
|
# test duplicate acknowledge
|
||||||
# broker.acknowledge(task[0])
|
broker.acknowledge(task[0])
|
||||||
#
|
|
||||||
# this crashes Disque when followed by a JSCAN
|
|
||||||
# https://github.com/antirez/disque/issues/113
|
|
||||||
# confirmed fix and merge is on the way
|
|
||||||
#
|
|
||||||
# delete queue
|
# delete queue
|
||||||
broker.enqueue('test')
|
broker.enqueue('test')
|
||||||
broker.enqueue('test')
|
broker.enqueue('test')
|
||||||
|
|||||||
Reference in New Issue
Block a user