From 4062b46b3a96f655e530dd44df2052630c4b172b Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Sun, 14 Jun 2026 12:13:14 +0000 Subject: [PATCH 1/2] Initial plan From 21521959862ebc332d3bcd6dfe9829c54efcabb5 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Sun, 14 Jun 2026 12:17:48 +0000 Subject: [PATCH 2/2] Stabilize flaky batch use case test --- .../impl/api/LocalConnectorInfoManagerTests.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/OpenICF-java-framework/connector-framework-internal/src/test/java/org/identityconnectors/framework/impl/api/LocalConnectorInfoManagerTests.java b/OpenICF-java-framework/connector-framework-internal/src/test/java/org/identityconnectors/framework/impl/api/LocalConnectorInfoManagerTests.java index 355c45e3..881c07d2 100644 --- a/OpenICF-java-framework/connector-framework-internal/src/test/java/org/identityconnectors/framework/impl/api/LocalConnectorInfoManagerTests.java +++ b/OpenICF-java-framework/connector-framework-internal/src/test/java/org/identityconnectors/framework/impl/api/LocalConnectorInfoManagerTests.java @@ -48,6 +48,7 @@ import org.identityconnectors.framework.common.objects.Subscription; import org.identityconnectors.framework.common.objects.Uid; import org.identityconnectors.framework.api.operations.batch.BatchBuilder; +import org.identityconnectors.framework.api.operations.batch.BatchTask; import org.testng.Assert; import org.testng.annotations.Test; @@ -319,15 +320,16 @@ public void onNext(BatchResult batchResult) { } }; - Subscription sub = facade.executeBatch(batch.build(), observer, options); - assertEquals(results.size(), 0); - assertFalse(isComplete.get()); - assertFalse(hasError.get()); + final List batchTasks = batch.build(); + Subscription sub = facade.executeBatch(batchTasks, observer, options); assertNotNull(sub.getReturnValue()); - Thread.sleep(500); + final long timeout = System.currentTimeMillis() + 3000; + while (!isComplete.get() && System.currentTimeMillis() < timeout) { + Thread.sleep(100); + } - assertEquals(results.size(), batch.build().size()); + assertEquals(results.size(), batchTasks.size()); assertTrue(isComplete.get()); assertFalse(hasError.get());