diff --git a/Partner-Core/src/main/java/work/slhaf/partner/module/action/executor/ActionExecutor.java b/Partner-Core/src/main/java/work/slhaf/partner/module/action/executor/ActionExecutor.java index d0ca8697..7cd22684 100644 --- a/Partner-Core/src/main/java/work/slhaf/partner/module/action/executor/ActionExecutor.java +++ b/Partner-Core/src/main/java/work/slhaf/partner/module/action/executor/ActionExecutor.java @@ -63,6 +63,9 @@ public class ActionExecutor extends AbstractAgentModule.Standalone { recoveredActions.addAll(actionCapability.listActions(Action.Status.INTERRUPTED, null).stream() .peek(executableAction -> executableAction.setStatus(Action.Status.EXECUTING)) .collect(Collectors.toSet())); + if (recoveredActions.isEmpty()) { + return; + } recoveredActions.forEach(this::execute); blockManager.emitActionRecoveredBlock(recoveredActions); }