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

Added tests for failures filtering

Browse Source 
fixed a bug
This commit is contained in:
Ilan
2015-07-19 15:21:06 +02:00
parent 52e72fde1c
commit d7ecaee18d
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
django_q/models.py
View File

@@ -64,7 +64,7 @@ class Task(models.Model):
def get_task_group(group_id, failures=True):
if failures:
return Task.objects.filter(group=group_id)
return Task.objects.filter(group_id=group_id).exclude(success=False)
return Task.objects.filter(group=group_id).exclude(success=False)
def time_taken(self):
return (self.stopped - self.started).total_seconds()

2
django_q/tests/test_cluster.py
View File

@@ -202,7 +202,9 @@ def test_async(r, admin_user):
assert result(result_j.name) == result_j.result
# groups
assert result_group('test_j') == [result_j.result]
assert result_group('test_j', failures=True) == [result_j.result]
assert fetch_group('test_j')[0].id == [result_j][0].id
assert fetch_group('test_j', failures=False)[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