mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-07 05:18:12 +08:00
updated delete job test
This commit is contained in:
@@ -72,7 +72,7 @@ def test_disque():
|
|||||||
# 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)
|
||||||
|
|||||||
Reference in New Issue
Block a user