Remove unused script update method

Signed-off-by: Daniel Widdis <[email protected]>
dbwiddis · Oct 2, 2024 · f6c194e · f6c194e
1 parent 9c041ef
commit f6c194e
Showing 1 changed file with 0 additions and 35 deletions.
diff --git a/src/main/java/org/opensearch/flowframework/indices/FlowFrameworkIndicesHandler.java b/src/main/java/org/opensearch/flowframework/indices/FlowFrameworkIndicesHandler.java
@@ -47,7 +47,6 @@
 import org.opensearch.flowframework.util.ParseUtils;
 import org.opensearch.flowframework.workflow.WorkflowData;
 import org.opensearch.index.engine.VersionConflictEngineException;
-import org.opensearch.script.Script;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -665,40 +664,6 @@ public void deleteFlowFrameworkSystemIndexDoc(String documentId, ActionListener<
         }
     }
 
-    /**
-     * Updates a document in the workflow state index
-     * @param indexName the index that we will be updating a document of.
-     * @param documentId the document ID
-     * @param script the given script to update doc
-     * @param listener action listener
-     */
-    public void updateFlowFrameworkSystemIndexDocWithScript(
-        String indexName,
-        String documentId,
-        Script script,
-        ActionListener<UpdateResponse> listener
-    ) {
-        if (!doesIndexExist(indexName)) {
-            String errorMessage = "Failed to update document for given workflow due to missing " + indexName + " index";
-            logger.error(errorMessage);
-            listener.onFailure(new Exception(errorMessage));
-        } else {
-            try (ThreadContext.StoredContext context = client.threadPool().getThreadContext().stashContext()) {
-                UpdateRequest updateRequest = new UpdateRequest(indexName, documentId);
-                // TODO: Also add ability to change other fields at the same time when adding detailed provision progress
-                updateRequest.script(script);
-                updateRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
-                updateRequest.retryOnConflict(3);
-                // TODO: Implement our own concurrency control to improve on retry mechanism
-                client.update(updateRequest, ActionListener.runBefore(listener, context::restore));
-            } catch (Exception e) {
-                String errorMessage = "Failed to update " + indexName + " entry : " + documentId;
-                logger.error(errorMessage, e);
-                listener.onFailure(new FlowFrameworkException(errorMessage, ExceptionsHelper.status(e)));
-            }
-        }
-    }
-
     /**
      * Adds a resource to the state index, including common exception handling
      * @param currentNodeInputs Inputs to the current node