Fix Admin Issue with Djongo DB Engine(Mongodb Engine)

django_q/admin.py

@@ -5,7 +5,8 @@
 from django_q.conf import Conf, croniter
 from django_q.models import Failure, OrmQ, Schedule, Success
 from django_q.tasks import async_task
-
+from django.db.models import Q
+from django.db import connection
 
 class TaskAdmin(admin.ModelAdmin):
     """model admin for success tasks."""
@@ -19,7 +20,14 @@ def has_add_permission(self, request):
     def get_queryset(self, request):
         """Only show successes."""
         qs = super(TaskAdmin, self).get_queryset(request)
-        return qs.filter(success=True)
+        if connection.vendor == "djongo":
+            ids=[]
+            for data in qs.filter(Q(attempt_count__gt = 0)):
+                if data.success:
+                    ids.append(data.id)
+            return qs.filter(id__in = ids)
+        else:
+            return qs.filter(success=True)
 
     search_fields = ("name", "func", "group")
     readonly_fields = []

django_q/models.py

@@ -7,6 +7,8 @@
 from django.utils import timezone
 from django.utils.html import format_html
 from django.utils.translation import gettext_lazy as _
+from django.db import connection
+from django.db.models import Q
 
 # External
 from picklefield import PickledObjectField
@@ -107,8 +109,15 @@ class Meta:
 
 class SuccessManager(models.Manager):
     def get_queryset(self):
-        return super(SuccessManager, self).get_queryset().filter(success=True)
-
+        qs = super(SuccessManager, self).get_queryset()
+        if connection.vendor == "djongo":
+            ids=[]
+            for data in qs.filter(Q(attempt_count__gte= 0)):
+                if data.success:
+                    ids.append(data.id)
+            return qs.filter(id__in = ids)
+        else:
+            return qs.filter(success=True)
 
 class Success(Task):
     objects = SuccessManager()
@@ -123,8 +132,15 @@ class Meta:
 
 class FailureManager(models.Manager):
     def get_queryset(self):
-        return super(FailureManager, self).get_queryset().filter(success=False)
-
+        qs = super(FailureManager, self).get_queryset()
+        if connection.vendor == "djongo":
+            ids=[]
+            for data in qs.filter(Q(attempt_count__gte= 0)):
+                if not data.success:
+                    ids.append(data.id)
+            return qs.filter(id__in = ids)
+        else:
+            return qs.filter(success=False)
 
 class Failure(Task):
     objects = FailureManager()

django_q/monitor.py

@@ -35,6 +35,7 @@ def get_process_mb(pid):
 def monitor(run_once=False, broker=None):
     if not broker:
         broker = get_broker()
+
     term = Terminal()
     broker.ping()
     with term.fullscreen(), term.hidden_cursor(), term.cbreak():
@@ -215,7 +216,7 @@ def info(broker=None):
     tasks_per_day = last_tasks.count()
     if tasks_per_day > 0:
         # average execution time over the last 24 hours
-        if connection.vendor != "sqlite":
+        if connection.vendor != "sqlite" and connection.vendor != "djongo":
             exec_time = last_tasks.aggregate(
                 time_taken=Sum(F("stopped") - F("started"))
             )