diff --git a/x-pack/plugins/integration_assistant/server/templates/pipeline.yml.njk b/x-pack/plugins/integration_assistant/server/templates/pipeline.yml.njk
index ba846dc50fba9..d583d68c4b733 100644
--- a/x-pack/plugins/integration_assistant/server/templates/pipeline.yml.njk
+++ b/x-pack/plugins/integration_assistant/server/templates/pipeline.yml.njk
@@ -19,11 +19,11 @@ processors:
       field: originalMessage
       ignore_missing: true
       tag: remove_copied_message
-      if: 'ctx.event?.original != null'
+      if: 'ctx.event?.original != null'{% if log_format != 'unstructured' %}
   - remove:
       field: message
       ignore_missing: true
-      tag: remove_message{% if (log_format == 'json') or (log_format == 'ndjson') %}
+      tag: remove_message{% endif %}{% if (log_format == 'json') or (log_format == 'ndjson') %}
   - json:
       field: event.original
       tag: json_original