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

fixed typo and added group tests

Browse Source
This commit is contained in:
Ilan
2015-07-19 13:56:16 +02:00
parent ff102630f7
commit e75fbecda8
2 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_cluster.py
+10 -1
View File
@@ -10,7 +10,7 @@ sys.path.insert(0, myPath + '/../')
from django_q.cluster import Cluster, Sentinel, pusher, worker, monitor
from django_q.humanhash import DEFAULT_WORDLIST
from django_q.tasks import fetch, fetch_group, async, result, result_group
from django_q.tasks import fetch, fetch_group, async, result, result_group, count_group, delete_group
from django_q.models import Task
from django_q.conf import Conf, redis_client
from .tasks import multiply
@@ -197,8 +197,17 @@ def test_async(r, admin_user):
assert result_j is not None
assert result_j.success is True
assert result_j.result == result_j.args[0].id
# check fetch, result by name
assert fetch(result_j.name) == result_j
assert result(result_j.name) == result_j.result
# groups
assert result_group('test_j') == [result_j.result]
assert fetch_group('test_j')[0].id == [result_j][0].id
assert count_group('test_j') == 1
assert count_group('test_j', failures=True) == 0
assert delete_group('test_j') == 1
assert delete_group('test_j', tasks=True) is None
r.delete(list_key)