Fix compilation for transport actions now that task is required

elastic · Jun 26, 2019 · 6393ac8 · 6393ac8
1 parent a26e302
commit 6393ac8
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/.../elasticsearch/xpack/snapshotlifecycle/action/TransportDeleteSnapshotLifecycleAction.java b/.../elasticsearch/xpack/snapshotlifecycle/action/TransportDeleteSnapshotLifecycleAction.java
@@ -19,6 +19,7 @@
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.tasks.Task;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 import org.elasticsearch.xpack.core.snapshotlifecycle.SnapshotLifecycleMetadata;
@@ -56,7 +57,7 @@ protected DeleteSnapshotLifecycleAction.Response read(StreamInput in) throws IOE
     }
 
     @Override
-    protected void masterOperation(DeleteSnapshotLifecycleAction.Request request,
+    protected void masterOperation(Task task, DeleteSnapshotLifecycleAction.Request request,
                                    ClusterState state,
                                    ActionListener<DeleteSnapshotLifecycleAction.Response> listener) throws Exception {
         clusterService.submitStateUpdateTask("delete-snapshot-lifecycle-" + request.getLifecycleId(),

diff --git a/...elasticsearch/xpack/snapshotlifecycle/action/TransportExecuteSnapshotLifecycleAction.java b/...elasticsearch/xpack/snapshotlifecycle/action/TransportExecuteSnapshotLifecycleAction.java
@@ -20,6 +20,7 @@
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.tasks.Task;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 import org.elasticsearch.xpack.core.snapshotlifecycle.SnapshotLifecycleMetadata;
@@ -65,7 +66,7 @@ protected ExecuteSnapshotLifecycleAction.Response read(StreamInput in) throws IO
     }
 
     @Override
-    protected void masterOperation(final ExecuteSnapshotLifecycleAction.Request request,
+    protected void masterOperation(final Task task, final ExecuteSnapshotLifecycleAction.Request request,
                                    final ClusterState state,
                                    final ActionListener<ExecuteSnapshotLifecycleAction.Response> listener) {
         try {

diff --git a/...org/elasticsearch/xpack/snapshotlifecycle/action/TransportGetSnapshotLifecycleAction.java b/...org/elasticsearch/xpack/snapshotlifecycle/action/TransportGetSnapshotLifecycleAction.java
@@ -18,6 +18,7 @@
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.tasks.Task;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 import org.elasticsearch.xpack.core.snapshotlifecycle.SnapshotLifecycleMetadata;
@@ -59,7 +60,7 @@ protected GetSnapshotLifecycleAction.Response read(StreamInput in) throws IOExce
     }
 
     @Override
-    protected void masterOperation(final GetSnapshotLifecycleAction.Request request,
+    protected void masterOperation(final Task task, final GetSnapshotLifecycleAction.Request request,
                                    final ClusterState state,
                                    final ActionListener<GetSnapshotLifecycleAction.Response> listener) {
         SnapshotLifecycleMetadata snapMeta = state.metaData().custom(SnapshotLifecycleMetadata.TYPE);

diff --git a/...org/elasticsearch/xpack/snapshotlifecycle/action/TransportPutSnapshotLifecycleAction.java b/...org/elasticsearch/xpack/snapshotlifecycle/action/TransportPutSnapshotLifecycleAction.java
@@ -20,6 +20,7 @@
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.tasks.Task;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 import org.elasticsearch.xpack.core.ClientHelper;
@@ -66,7 +67,7 @@ protected PutSnapshotLifecycleAction.Response read(StreamInput in) throws IOExce
     }
 
     @Override
-    protected void masterOperation(final PutSnapshotLifecycleAction.Request request,
+    protected void masterOperation(final Task task, final PutSnapshotLifecycleAction.Request request,
                                    final ClusterState state,
                                    final ActionListener<PutSnapshotLifecycleAction.Response> listener) {
         SnapshotLifecycleService.validateRepositoryExists(request.getLifecycle().getRepository(), state);