From a1dcf4a6fa672e1e2eed5238ce58cf3f5f933b69 Mon Sep 17 00:00:00 2001
From: slhafzjw <slhafzjw@slhaf.work>
Date: Thu, 5 Feb 2026 17:05:53 +0800
Subject: [PATCH] test(ActionExecutor): test with action failure

---
 .../action/dispatcher/executor/ActionExecutorTest.java   | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java b/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java
index f641c904..8a64a9ea 100644
--- a/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java
+++ b/Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java
@@ -228,8 +228,9 @@ class ActionExecutorTest {
     // 场景7：B7.2(失败) -> repairer FAILED。目的：验证失败分支不提交外部执行。
     @Test
     void execute_extractorFail_thenRepairFailed() {
-        ExecutorService directExecutor = new DirectExecutorService();
-        stubExecutors(directExecutor, directExecutor);
+        ExecutorService platformExecutor = Executors.newFixedThreadPool(4);
+        ExecutorService virtualExecutor = Executors.newVirtualThreadPerTaskExecutor();
+        stubExecutors(platformExecutor, virtualExecutor);
 
         ImmediateActionData actionData = buildActionData(singleStageChain(false));
         ActionExecutorInput input = buildInput("u1", actionData);
@@ -245,6 +246,10 @@ class ActionExecutorTest {
         actionExecutor.init();
         actionExecutor.execute(input);
 
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException ignored) {
+        }
         MetaAction metaAction = actionData.getActionChain().get(0).get(0);
         assertEquals(MetaAction.ResultStatus.FAILED, metaAction.getResult().getStatus());
         verify(runnerClient, never()).submit(any(MetaAction.class));