From 6127b551aefe5f807570f31b97d1aa6a8c1488a3 Mon Sep 17 00:00:00 2001 From: Ilan Steemers Date: Thu, 1 Oct 2015 17:21:26 +0200 Subject: [PATCH] fixes tests for cache with better coverage --- django_q/tasks.py | 2 +- django_q/tests/test_cached.py | 11 ++++++++--- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/django_q/tasks.py b/django_q/tasks.py index 25d8e8c..20e8af3 100644 --- a/django_q/tasks.py +++ b/django_q/tasks.py @@ -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. diff --git a/django_q/tests/test_cached.py b/django_q/tests/test_cached.py index ba44d11..cfc0934 100644 --- a/django_q/tests/test_cached.py +++ b/django_q/tests/test_cached.py @@ -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