slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 16:53:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(ActionExecutor): test with additionalContext appending

Browse Source
This commit is contained in:
slhafzjw
2026-02-05 16:58:22 +08:00
parent 33df0fa017
commit 9c38719514
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java
View File

@@ -190,8 +190,9 @@ class ActionExecutorTest {
// 场景6：B7.2(失败) -> repairer OK -> B7(成功)。目的：验证修复后成功与上下文追加。 // 场景6：B7.2(失败) -> repairer OK -> B7(成功)。目的：验证修复后成功与上下文追加。
@Test @Test
void execute_extractorFail_thenRepairOk_thenSuccess() { void execute_extractorFail_thenRepairOk_thenSuccess() {
ExecutorService directExecutor = new DirectExecutorService(); ExecutorService platformExecutor = Executors.newFixedThreadPool(4);
stubExecutors(directExecutor, directExecutor); ExecutorService virtualExecutor = Executors.newVirtualThreadPerTaskExecutor();
stubExecutors(platformExecutor, virtualExecutor);
ImmediateActionData actionData = buildActionData(singleStageChain(false)); ImmediateActionData actionData = buildActionData(singleStageChain(false));
ActionExecutorInput input = buildInput("u1", actionData); ActionExecutorInput input = buildInput("u1", actionData);
@@ -216,8 +217,12 @@ class ActionExecutorTest {
actionExecutor.init(); actionExecutor.init();
actionExecutor.execute(input); actionExecutor.execute(input);
try {
Thread.sleep(500);
} catch (InterruptedException ignored) {
}
assertEquals(1, actionData.getAdditionalContext().get(0).size()); assertEquals(1, actionData.getAdditionalContext().get(0).size());
verify(runnerClient, times(1)).submit(any(MetaAction.class)); verify(runnerClient, timeout(5000).times(1)).submit(any(MetaAction.class));
} }
// 场景7：B7.2(失败) -> repairer FAILED。目的：验证失败分支不提交外部执行。 // 场景7：B7.2(失败) -> repairer FAILED。目的：验证失败分支不提交外部执行。