fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-09-29 18:38:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixes tests for cache with better coverage

Browse Source
This commit is contained in:
Ilan Steemers
2015-10-01 17:21:26 +02:00
parent 7107e9ea35
commit 6127b551ae
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tasks.py
+1 -1
View File
@@ -266,7 +266,7 @@ def count_group_cached(group_id, failures=False, broker=None):
return failure_count
def delete_group(group_id, tasks=False, cached=Conf.CACHE):
def delete_group(group_id, tasks=False, cached=Conf.CACHED):
"""
Delete a group.
django_q/tests/test_cached.py
+8 -3
View File
@@ -31,6 +31,10 @@ def test_cached(broker):
async('math.copysign', 1, -1, cached=True, broker=broker, group=group)
async('math.copysign', 1, -1, cached=True, broker=broker, group=group)
async('math.copysign', 1, -1, cached=True, broker=broker, group=group)
async('math.popysign', 1, -1, cached=True, broker=broker, group=group)
# test wait on cache
assert result(task_id, wait=1, cached=True) is None
assert fetch(task_id, wait=1, cached=True) is None
# run a single cluster
start_event = Event()
stop_event = Event()
@@ -42,10 +46,11 @@ def test_cached(broker):
# make sure it's not in the db backend
assert fetch(task_id) is None
# assert group
assert count_group(group, cached=True) == 5
assert count_group(group, cached=True, failures=True) == 0
assert count_group(group, cached=True) == 6
assert count_group(group, cached=True, failures=True) == 1
assert result_group(group, cached=True) == [-1, -1, -1, -1, -1]
assert len(fetch_group(group, cached=True)) == 5
assert len(result_group(group, cached=True, failures=True)) == 6
assert len(fetch_group(group, cached=True)) == 6
assert len(fetch_group(group, cached=True, failures=False)) == 5
delete_group(group, cached=True)
assert count_group(group, cached=True) is None