Fix javadocs

Signed-off-by: Daniel Widdis <[email protected]>

src/main/java/demo/CreateIndexWorkflowStep.java

@@ -18,12 +18,18 @@
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 
+/**
+ * Sample to show other devs how to pass data around.  Will be deleted once other PRs are merged.
+ */
 public class CreateIndexWorkflowStep implements WorkflowStep {
 
     private static final Logger logger = LogManager.getLogger(CreateIndexWorkflowStep.class);
 
     private final String name;
 
+    /**
+     * Instantiate this class.
+     */
     public CreateIndexWorkflowStep() {
         this.name = "CREATE_INDEX";
     }

src/main/java/demo/DemoWorkflowStep.java

@@ -14,11 +14,18 @@
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
+/**
+ * Demo workflowstep to show sequenced execution
+ */
 public class DemoWorkflowStep implements WorkflowStep {
 
     private final long delay;
     private final String name;
 
+    /**
+     * Instantiate a step with a delay.
+     * @param delay milliseconds to take pretending to do work while really sleeping
+     */
     public DemoWorkflowStep(long delay) {
         this.delay = delay;
         this.name = "DEMO_DELAY_" + delay;

src/test/java/org/opensearch/flowframework/template/ProcessNodeTests.java

@@ -8,6 +8,9 @@
  */
 package org.opensearch.flowframework.template;
 
+import com.carrotsearch.randomizedtesting.annotations.ThreadLeakScope;
+import com.carrotsearch.randomizedtesting.annotations.ThreadLeakScope.Scope;
+
 import org.opensearch.flowframework.workflow.WorkflowData;
 import org.opensearch.flowframework.workflow.WorkflowStep;
 import org.opensearch.test.OpenSearchTestCase;
@@ -17,6 +20,7 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 
+@ThreadLeakScope(Scope.NONE)
 public class ProcessNodeTests extends OpenSearchTestCase {
 
     @Override
@@ -41,7 +45,7 @@ public String getName() {
         assertEquals("A", nodeA.id());
         assertEquals("test", nodeA.workflowStep().getName());
         assertEquals(WorkflowData.EMPTY, nodeA.input());
-        // FIXME: This is causing thread leaks
+        // TODO: Once we can get OpenSearch Thread Pool for this execute method, create an IT and don't test execute here
         CompletableFuture<WorkflowData> f = nodeA.execute();
         assertEquals(f, nodeA.getFuture());
         f.orTimeout(5, TimeUnit.SECONDS);