Sync rooms in separate tasks

aleksis/apps/matrix/model_extensions.py

@@ -22,7 +22,6 @@ def provision_in_matrix(self, sync: bool = False) -> Union[MatrixRoom, AsyncResu
 def _provision_in_matrix(self) -> MatrixRoom:
     """Create and sync a room for this group in Matrix."""
     room = MatrixRoom.from_group(self)
-    room.sync()
     return room
 
 

aleksis/apps/matrix/signals.py

@@ -8,9 +8,6 @@ from .tasks import sync_room
 
 def post_save_matrix_signal(sender, instance, created, **kwargs):
     """Sync Matrix room after changing a group/Matrix room/Matrix profile."""
-    if created:
-        return
-
     rooms = []
     if isinstance(instance, Group):
         rooms = MatrixRoom.objects.filter(group=instance)

aleksis/apps/matrix/tasks.py

 from datetime import timedelta
 from typing import Sequence
 
+from celery.task.sets import TaskSet
+
 from aleksis.apps.matrix.models import MatrixRoom
 from aleksis.core.celery import app
 from aleksis.core.models import Group
@@ -33,4 +35,4 @@ def sync_rooms():
     """Synchronise all Matrix rooms."""
     rooms = MatrixRoom.objects.all()
     for room in rooms:
-        room.sync()
+        sync_room.delay(room.pk)