diff --git a/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/delete/DeletePipelineTransportAction.java b/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/delete/DeletePipelineTransportAction.java
index b57a3db00c9..c8b60a0252f 100644
--- a/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/delete/DeletePipelineTransportAction.java
+++ b/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/delete/DeletePipelineTransportAction.java
@@ -26,17 +26,12 @@ import org.elasticsearch.action.delete.TransportDeleteAction;
 import org.elasticsearch.action.support.ActionFilters;
 import org.elasticsearch.action.support.HandledTransportAction;
 import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
-import org.elasticsearch.common.bytes.BytesReference;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.plugin.ingest.PipelineStore;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
 public class DeletePipelineTransportAction extends HandledTransportAction<DeletePipelineRequest, DeletePipelineResponse> {
 
     private final TransportDeleteAction deleteAction;
@@ -49,7 +44,7 @@ public class DeletePipelineTransportAction extends HandledTransportAction<Delete
 
     @Override
     protected void doExecute(DeletePipelineRequest request, ActionListener<DeletePipelineResponse> listener) {
-        DeleteRequest deleteRequest = new DeleteRequest();
+        DeleteRequest deleteRequest = new DeleteRequest(request);
         deleteRequest.index(PipelineStore.INDEX);
         deleteRequest.type(PipelineStore.TYPE);
         deleteRequest.id(request.id());
diff --git a/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/put/PutPipelineTransportAction.java b/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/put/PutPipelineTransportAction.java
index 542c0842627..b6c59ff8ed8 100644
--- a/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/put/PutPipelineTransportAction.java
+++ b/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/transport/put/PutPipelineTransportAction.java
@@ -59,7 +59,7 @@ public class PutPipelineTransportAction extends HandledTransportAction<PutPipeli
             return;
         }
 
-        IndexRequest indexRequest = new IndexRequest();
+        IndexRequest indexRequest = new IndexRequest(request);
         indexRequest.index(PipelineStore.INDEX);
         indexRequest.type(PipelineStore.TYPE);
         indexRequest.id(request.id());