celery: add async task to update the 'pending_review' attributes on all patches

Signed-off-by: andrepapoti <[email protected]>

Author: andrepapoti

patchwork/tasks.py

@@ -0,0 +1,27 @@
+from celery import shared_task
+from patchwork.celery import app
+from patchwork.models import Patch
+from patchwork.api.patch import PatchInterestSerializer
+
+
+@shared_task
+def update_patch_interest():
+    for patch in Patch.objects.all():
+        pending_review = False
+        for patch_interest in patch.interested_users.through.objects.filter(
+            patch=patch
+        ):
+            serializer = PatchInterestSerializer(patch_interest)
+            if not serializer.data['is_stale']:
+                pending_review = True
+                break
+        patch.pending_review = pending_review
+        patch.save()
+
+
+app.conf.beat_schedule = {
+    'update_patch_interest': {
+        'task': 'patchwork.tasks.update_patch_interest',
+        'schedule': 3600.0,
+    }
+}