Add clean job task on startup

backend/Dockerfile

@@ -77,6 +77,7 @@ ENV DJANGO_SETTINGS_MODULE=backend.production_settings
 RUN echo "python manage.py collectstatic --no-input --clear" > entrypoint.prod.sh
 RUN echo "sleep 3" >> entrypoint.prod.sh
 RUN echo "python manage.py migrate --noinput" >> entrypoint.prod.sh
+RUN echo "python manage.py clean_jobs" >> entrypoint.prod.sh
 RUN echo "python manage.py export_variants" >> entrypoint.prod.sh
 RUN echo "gunicorn backend.wsgi:application --bind 0.0.0.0:8000" >> entrypoint.prod.sh
 EXPOSE 8000

backend/spellbook/management/commands/clean_jobs.py

@@ -0,0 +1,25 @@
+from django.utils import timezone
+from django.core.management.base import BaseCommand
+from spellbook.models import Job
+
+
+class Command(BaseCommand):
+    help = 'Clean pending jobs'
+
+    def handle(self, *args, **options):
+        self.stdout.write('Cleaning pending jobs...')
+        query = Job.objects.filter(status=Job.Status.PENDING)
+        count = query.count()
+        if count > 0:
+            query.update(status=Job.Status.FAILURE, message='Job was cancelled.', termination=timezone.now())
+            now = timezone.now() + timezone.timedelta(seconds=2)
+            job = Job(
+                name="cancel_jobs",
+                expected_termination=now,
+                termination=now,
+                status=Job.Status.SUCCESS,
+                message=f"{count} pending jobs were cancelled.")
+            job.save()
+            self.stdout.write(self.style.SUCCESS(f"{count} pending jobs were cancelled."))
+        else:
+            self.stdout.write(self.style.SUCCESS("No pending jobs to cancel."))