From 5ef07f5a1ac725a66dc63e0a9094e796b13d9f39 Mon Sep 17 00:00:00 2001 From: Daniel Widdis Date: Mon, 25 Sep 2023 08:36:33 -0700 Subject: [PATCH] Disable flaky test Signed-off-by: Daniel Widdis --- .../flowframework/template/ProcessNodeTests.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/test/java/org/opensearch/flowframework/template/ProcessNodeTests.java b/src/test/java/org/opensearch/flowframework/template/ProcessNodeTests.java index 3feab9f3b..d9f365708 100644 --- a/src/test/java/org/opensearch/flowframework/template/ProcessNodeTests.java +++ b/src/test/java/org/opensearch/flowframework/template/ProcessNodeTests.java @@ -19,7 +19,6 @@ import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeUnit; @ThreadLeakScope(Scope.NONE) public class ProcessNodeTests extends OpenSearchTestCase { @@ -49,12 +48,13 @@ public String getName() { assertEquals(Collections.emptySet(), nodeA.getPredecessors()); assertEquals("A", nodeA.toString()); - // TODO: Once we can get OpenSearch Thread Pool for this execute method, create an IT and don't test execute here - CompletableFuture f = nodeA.execute(); - assertEquals(f, nodeA.getFuture()); - f.orTimeout(5, TimeUnit.SECONDS); - assertTrue(f.isDone()); - assertEquals(WorkflowData.EMPTY, f.get()); + // TODO: This test is flaky on Windows. Disabling until thread pool is integrated + // https://github.com/opensearch-project/opensearch-ai-flow-framework/issues/42 + // CompletableFuture f = nodeA.execute(); + // assertEquals(f, nodeA.future()); + // f.orTimeout(5, TimeUnit.SECONDS); + // assertTrue(f.isDone()); + // assertEquals(WorkflowData.EMPTY, f.get()); ProcessNode nodeB = new ProcessNode("B", null); assertNotEquals(nodeA, nodeB);