diff --git a/aggregator/models.py b/aggregator/models.py
index 8f8be8e..71b790e 100644
--- a/aggregator/models.py
+++ b/aggregator/models.py
@@ -4,7 +4,7 @@ from tempfile import TemporaryDirectory
 
 import pytz
 from django.conf import settings
-from django.db import models
+from django.db import models, transaction
 from pyrogram import Chat as PyrogramChat, Message as PyrogramMessage
 
 
@@ -49,6 +49,7 @@ class Chat(models.Model):
                 obj.photo_id = chat.photo.small_file_id
                 obj.save()
         if created:
+            transaction.commit()
             collect_new_messages.delay(obj.pk)
         return obj