OpenConceptLab/ocl_issues#1777 | celery tasks cleanup job to remove a…

…ny task older than 7 days

core/celery.py

@@ -29,7 +29,10 @@
         'task': 'core.common.tasks.vacuum_and_analyze_db',
         'schedule': crontab(0, 1),  # Run at 1 am
     },
-
+    'expire-celery-tasks': {
+        'task': 'core.common.tasks.expire_old_celery_tasks',
+        'schedule': crontab(0, 1),  # Run at 1 am
+    },
 }
 app.config_from_object('django.conf:settings', namespace='CELERY')
 app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

core/common/tasks.py

@@ -756,3 +756,9 @@ def resolve_url_registry_entries(repo_id, repo_type):
         repo = repo_klass.objects.filter(id=repo_id).first()
         for entry in repo.active_url_registry_entries:
             entry.lookup_entry()
+
+
+@app.task(ignore_result=True)
+def expire_old_celery_tasks():
+    from core.tasks.models import Task
+    Task.objects.filter(updated_at__lt=timezone.now() - timezone.timedelta(days=7)).delete()