diff --git a/django_q/models.py b/django_q/models.py
index c1594c0..43fbff3 100644
--- a/django_q/models.py
+++ b/django_q/models.py
@@ -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()
diff --git a/django_q/tests/test_cluster.py b/django_q/tests/test_cluster.py
index 1245292..2e347fa 100644
--- a/django_q/tests/test_cluster.py
+++ b/django_q/tests/test_cluster.py
@@ -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