async update of annotation matches, fixes deadlock in load_subtitles

pandora/annotation/models.py

@@ -134,6 +134,7 @@ class Annotation(models.Model):
 
     def save(self, *args, **kwargs):
         from .tasks import update_matches
+        async = kwargs.pop('async', False)
 
         set_public_id = not self.id or not self.public_id
         layer = self.get_layer()
@@ -181,10 +182,12 @@ class Annotation(models.Model):
                 self.clip.save()
 
             # editAnnotations needs to be in snyc
+            # load_subtitles can not be in sync
+            fn = update_matches.delay if async else update_matches
             if layer.get('type') == 'place' or layer.get('hasPlaces'):
-                update_matches(self.id, 'place')
+                fn(self.id, 'place')
             if layer.get('type') == 'event' or layer.get('hasEvents'):
-                update_matches(self.id, 'event')
+                fn(self.id, 'event')
 
     def delete(self, *args, **kwargs):
         with transaction.atomic():

pandora/annotation/tasks.py

@@ -18,7 +18,10 @@ def update_matches(id, type):
     elif type == 'event':
         from event.models import Event as Model
 
+    try:
         a = Annotation.objects.get(pk=id)
+    except Annotation.DoesNotExist:
+        return
     a_matches = getattr(a, type == 'place' and 'places' or 'events')
 
     # remove undefined matches that only have this annotation
@@ -33,8 +36,7 @@ def update_matches(id, type):
     if a.findvalue:
         names = {}
         for n in Model.objects.all().values('id', 'name', 'alternativeNames'):
-            names[n['id']] = [ox.decode_html(x)
-                for x in (n['name'],) + n['alternativeNames']]
+            names[n['id']] = [ox.decode_html(x) for x in (n['name'],) + n['alternativeNames']]
         value = a.findvalue.lower()
 
         current = [p.id for p in a_matches.all()]
@@ -54,9 +56,9 @@ def update_matches(id, type):
             if not filter(lambda n: n in name_matches,
                           [n.lower() for n in p.get_super_matches()]):
                 new.append(i)
-        removed = list(filter(lambda p: p not in new, current))
-        added = list(filter(lambda p: p not in current, new))
-        update = removed + added
+        removed = set(filter(lambda p: p not in new, current))
+        added = set(filter(lambda p: p not in current, new))
+        update = list(removed | added)
         if update:
             for e in Model.objects.filter(id__in=update):
                 e.update_matches(Annotation.objects.filter(pk=a.id))

pandora/item/models.py

@@ -1632,7 +1632,7 @@ class Item(models.Model):
                                     value=value,
                                     user=user
                                 )
-                                annotation.save()
+                                annotation.save(async=True)
                     # otherwise add empty 5 seconds annotation every minute
                     if not subtitles_added:
                         start = offset and int(offset / 60) * 60 + 60 or 0
@@ -1647,7 +1647,7 @@ class Item(models.Model):
                                 value='',
                                 user=user
                             )
-                            annotation.save()
+                            annotation.save(async=True)
                     offset += f.duration
                 # remove left over clips without annotations
                 Clip.objects.filter(item=self, annotations__id=None).delete()