Add update project

Author: samxbr

modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpDownloader.java

@@ -244,7 +244,7 @@ protected void updateTimestamp(String name, Metadata old) {
 
     void updateTaskState() {
         PlainActionFuture<PersistentTask<?>> future = new PlainActionFuture<>();
-        updatePersistentTaskState(state, future);
+        updateProjectPersistentTaskState(projectId, state, future);
         state = ((GeoIpTaskState) future.actionGet().getState());
     }
 

server/src/main/java/org/elasticsearch/persistent/AllocatedPersistentTask.java

@@ -12,6 +12,7 @@
 import org.apache.logging.log4j.Logger;
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.admin.cluster.node.tasks.cancel.CancelTasksRequest;
+import org.elasticsearch.cluster.metadata.ProjectId;
 import org.elasticsearch.core.Nullable;
 import org.elasticsearch.core.TimeValue;
 import org.elasticsearch.tasks.CancellableTask;
@@ -74,6 +75,26 @@ public void updatePersistentTaskState(
         );
     }
 
+    /**
+     * Updates the persistent state for the corresponding project scope persistent task.
+     * <p>
+     * This doesn't affect the status of this allocated task.
+     */
+    public void updateProjectPersistentTaskState(
+        final ProjectId projectId,
+        final PersistentTaskState state,
+        final ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener
+    ) {
+        persistentTasksService.sendProjectUpdateStateRequest(
+            projectId,
+            persistentTaskId,
+            allocationId,
+            state,
+            TimeValue.THIRTY_SECONDS /* TODO should this be longer? infinite? */,
+            listener
+        );
+    }
+
     public String getPersistentTaskId() {
         return persistentTaskId;
     }