mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-07 06:48:11 +08:00
adds count_group() and delete_group()
This commit is contained in:
@@ -37,6 +37,19 @@ class Task(models.Model):
|
||||
values = Task.objects.filter(group=group_id).values_list('result', flat=True)
|
||||
return [dbsafe_decode(t) for t in values]
|
||||
|
||||
@staticmethod
|
||||
def get_group_count(group_id, failures=False):
|
||||
if failures:
|
||||
return Failure.objects.filter(group=group_id).count()
|
||||
return Task.objects.filter(group=group_id).count()
|
||||
|
||||
@staticmethod
|
||||
def delete_group(group_id, objects=False):
|
||||
group = Task.objects.filter(group=group_id)
|
||||
if objects:
|
||||
return group.delete()
|
||||
return group.update(group_id=None)
|
||||
|
||||
@staticmethod
|
||||
def get_task(task_id):
|
||||
if len(task_id) == 32 and Task.objects.filter(id=task_id).exists():
|
||||
|
||||
Reference in New Issue
Block a user