Fix json pipeline

elastic · Jun 16, 2022 · 9abce63 · 9abce63
1 parent 324eb1f
commit 9abce63
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/x-pack/plugins/fleet/server/services/epm/elasticsearch/ingest_pipeline/install.ts b/x-pack/plugins/fleet/server/services/epm/elasticsearch/ingest_pipeline/install.ts
@@ -231,7 +231,10 @@ async function installPipeline({
 
   const esClientParams = {
     id: pipelineToInstall.nameForInstallation,
-    body: pipelineToInstall.contentForInstallation,
+    body:
+      pipelineToInstall.extension === 'yml'
+        ? pipelineToInstall.contentForInstallation
+        : JSON.parse(pipelineToInstall.contentForInstallation),
   };
 
   const esClientRequestOptions: TransportRequestOptions = {

diff --git a/x-pack/plugins/fleet/server/services/epm/elasticsearch/meta.ts b/x-pack/plugins/fleet/server/services/epm/elasticsearch/meta.ts
@@ -58,6 +58,6 @@ export function appendMetadataToIngestPipeline({
 
   return {
     ...pipeline,
-    contentForInstallation: parsedPipelineContent,
+    contentForInstallation: JSON.stringify(parsedPipelineContent),
   };
 }