Add maintenance function to remove old import tasks

kobo/settings/base.py

@@ -363,6 +363,11 @@
         'Number of days to keep asset snapshots',
         'positive_int'
     ),
+    'IMPORT_TASK_DAYS_RETENTION': (
+        90,
+        'Number of days to keep import tasks',
+        'positive_int',
+    ),
     'FREE_TIER_THRESHOLDS': (
         LazyJSONSerializable(FREE_TIER_NO_THRESHOLDS),
         'Free tier thresholds: storage in kilobytes, '
@@ -661,10 +666,13 @@
         'PROJECT_OWNERSHIP_AUTO_ACCEPT_INVITES',
     ),
     'Trash bin': (
-        'ASSET_SNAPSHOT_DAYS_RETENTION',
         'ACCOUNT_TRASH_GRACE_PERIOD',
         'PROJECT_TRASH_GRACE_PERIOD',
     ),
+    'Regular maintenance settings': (
+        'ASSET_SNAPSHOT_DAYS_RETENTION',
+        'IMPORT_TASK_DAYS_RETENTION',
+    ),
     'Tier settings': (
         'FREE_TIER_THRESHOLDS',
         'FREE_TIER_DISPLAY',

kpi/maintenance_tasks.py

@@ -4,7 +4,8 @@
 from django.db.models import Exists, OuterRef, Q
 from django.utils import timezone
 
-from kpi.models import AssetSnapshot
+from kpi.models import AssetSnapshot, ImportTask
+from kpi.utils.chunked_delete import chunked_delete
 
 
 def remove_old_asset_snapshots():
@@ -20,9 +21,14 @@ def remove_old_asset_snapshots():
         date_created__lt=timezone.now() - timedelta(days=days),
     ).filter(Exists(newer_snapshot_for_asset) | Q(asset_version=None))
 
-    while True:
-        count, _ = delete_queryset.filter(
-            pk__in=delete_queryset[:1000]
-        ).delete()
-        if not count:
-            break
+    chunked_delete(delete_queryset)
+
+
+def remove_old_import_tasks():
+    days = constance.config.IMPORT_TASK_DAYS_RETENTION
+
+    delete_queryset = ImportTask.objects.filter(
+        date_created__lt=timezone.now() - timedelta(days=days),
+    )
+
+    chunked_delete(delete_queryset)

kpi/tasks.py

@@ -9,7 +9,7 @@
 from kobo.apps.markdownx_uploader.tasks import remove_unused_markdown_files
 from kobo.celery import celery_app
 from kpi.constants import LIMIT_HOURS_23
-from kpi.maintenance_tasks import remove_old_asset_snapshots
+from kpi.maintenance_tasks import remove_old_asset_snapshots, remove_old_import_tasks
 from kpi.models.asset import Asset
 from kpi.models.import_export_task import (
     ExportTask,
@@ -102,4 +102,5 @@ def perform_maintenance():
     Run daily maintenance tasks
     """
     remove_unused_markdown_files()
+    remove_old_import_tasks()
     remove_old_asset_snapshots()

kpi/tests/test_import_tasks.py

@@ -0,0 +1,33 @@
+# coding: utf-8
+from datetime import timedelta
+
+from django.contrib.auth import get_user_model
+from django.utils import timezone
+
+from kpi.maintenance_tasks import remove_old_import_tasks
+from kpi.models import ImportTask
+from kpi.tests.base_test_case import BaseTestCase
+
+
+class AssetImportTaskHousekeepingTest(BaseTestCase):
+    fixtures = ['test_data']
+
+    def setUp(self):
+        User = get_user_model()
+        self.user = User.objects.get(username='someuser')
+
+    def test_remove_old_import_tasks(self):
+        old_task = ImportTask.objects.create(
+            user=self.user,
+            data='{}',
+        )
+        # Because of `auto_date_now`, we cannot specify created_date on creation
+        old_task.date_created = timezone.now() - timedelta(days=95)
+        old_task.save(update_fields=['date_created'])
+
+        new_task = ImportTask.objects.create(user=self.user, data='{}')
+
+        remove_old_import_tasks()
+
+        assert ImportTask.objects.filter(id=new_task.id).exists()
+        assert not ImportTask.objects.filter(id=old_task.id).exists()

kpi/utils/chunked_delete.py

@@ -0,0 +1,8 @@
+from django.db.models import QuerySet
+
+
+def chunked_delete(queryset: QuerySet):
+    while True:
+        count, _ = queryset.filter(pk__in=queryset[:1000]).delete()
+        if not count:
+            break