Add refresh policy to logstash plugin write requests (#62583) (#62665)

Author: williamrandolph

x-pack/plugin/logstash/src/main/java/org/elasticsearch/xpack/logstash/action/TransportDeletePipelineAction.java

@@ -10,6 +10,7 @@
 import org.elasticsearch.action.DocWriteResponse.Result;
 import org.elasticsearch.action.support.ActionFilters;
 import org.elasticsearch.action.support.HandledTransportAction;
+import org.elasticsearch.action.support.WriteRequest;
 import org.elasticsearch.client.Client;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.tasks.Task;
@@ -31,6 +32,7 @@ protected void doExecute(Task task, DeletePipelineRequest request, ActionListene
         client.prepareDelete()
             .setIndex(Logstash.LOGSTASH_CONCRETE_INDEX_NAME)
             .setId(request.id())
+            .setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE)
             .execute(
                 ActionListener.wrap(
                     deleteResponse -> listener.onResponse(new DeletePipelineResponse(deleteResponse.getResult() == Result.DELETED)),

x-pack/plugin/logstash/src/main/java/org/elasticsearch/xpack/logstash/action/TransportPutPipelineAction.java

@@ -9,6 +9,7 @@
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.support.ActionFilters;
 import org.elasticsearch.action.support.HandledTransportAction;
+import org.elasticsearch.action.support.WriteRequest;
 import org.elasticsearch.client.Client;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.tasks.Task;
@@ -31,6 +32,7 @@ protected void doExecute(Task task, PutPipelineRequest request, ActionListener<P
             .setIndex(Logstash.LOGSTASH_CONCRETE_INDEX_NAME)
             .setId(request.id())
             .setSource(request.source(), request.xContentType())
+            .setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE)
             .execute(
                 ActionListener.wrap(
                     indexResponse -> listener.onResponse(new PutPipelineResponse(indexResponse.status())),

x-pack/plugin/src/javaRestTest/java/org/elasticsearch/xpack/test/rest/LogstashSystemIndexIT.java

@@ -50,7 +50,6 @@ public void testTemplateIsPut() throws Exception {
         );
     }
 
-    @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/62413")
     public void testPipelineCRUD() throws Exception {
         // put pipeline
         final String pipelineJson = getPipelineJson();