diff --git a/aggregator/signals.py b/aggregator/signals.py
index cb93ab0..803d8f6 100644
--- a/aggregator/signals.py
+++ b/aggregator/signals.py
@@ -1,4 +1,3 @@
-from django.db import transaction
 from pyrogram import Error
 
 from .client import get_client
@@ -13,7 +12,7 @@ def aggregation_source_deleted(sender, instance: AggregationSource, **kwargs):
 
 def chat_created(sender, instance: Chat, created, **kwargs):
     if created:
-        transaction.on_commit(lambda: collect_new_messages.delay(instance.pk))
+        collect_new_messages.delay(instance.pk)
 
 
 def chat_deleted(sender, instance: Chat, **kwargs):