fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-02 20:28:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

test for lock size in monitor

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-19 17:25:02 +02:00
parent 7532cac93a
commit dc47ebef3c
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_monitor.py
+8 -3
View File
@@ -1,6 +1,6 @@
import pytest import pytest
from django_q import async from django_q import async, get_broker
from django_q.cluster import Cluster from django_q.cluster import Cluster
from django_q.monitor import monitor, info from django_q.monitor import monitor, info
from django_q.status import Stat from django_q.status import Stat
@@ -23,9 +23,14 @@ def test_monitor():
assert stat.empty_queues() is True assert stat.empty_queues() is True
break break
assert found_c is True assert found_c is True
# test lock size for orm broker # test lock size
Conf.ORM = 'default' Conf.ORM = 'default'
monitor(run_once=True) b = get_broker('monitor_test')
b.enqueue('test')
b.dequeue()
assert b.lock_size() == 1
monitor(run_once=True, broker=b)
b.delete_queue()
Conf.ORM = None Conf.ORM = None