diff --git a/app/services/data_imports/intercom/message_batch_builder.rb b/app/services/data_imports/intercom/message_batch_builder.rb
index 5990e74a4..852b51c3c 100644
--- a/app/services/data_imports/intercom/message_batch_builder.rb
+++ b/app/services/data_imports/intercom/message_batch_builder.rb
@@ -106,7 +106,7 @@ class DataImports::Intercom::MessageBatchBuilder
   def build_entry(source_entry, position, mappings, messages)
     source_id = source_entry[:source_id]
     mapping = mappings[source_id]
-    mapped_message = messages[:by_id][mapping&.chatwoot_record_id]
+    mapped_message = messages[:by_id][mapping.chatwoot_record_id] if mapping&.chatwoot_record_type == 'Message'
     existing_message = messages[:by_source_id]["intercom:#{source_id}"]
 
     Entry.new(