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

refactor(action): register no blocks while no actions recovered

Browse Source
This commit is contained in:
slhafzjw
2026-04-19 00:51:22 +08:00
parent bfa3562335
commit 864bda95e4
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Partner-Core/src/main/java/work/slhaf/partner/module/action/executor/ActionExecutor.java
View File

@@ -63,6 +63,9 @@ public class ActionExecutor extends AbstractAgentModule.Standalone {
recoveredActions.addAll(actionCapability.listActions(Action.Status.INTERRUPTED, null).stream() recoveredActions.addAll(actionCapability.listActions(Action.Status.INTERRUPTED, null).stream()
.peek(executableAction -> executableAction.setStatus(Action.Status.EXECUTING)) .peek(executableAction -> executableAction.setStatus(Action.Status.EXECUTING))
.collect(Collectors.toSet())); .collect(Collectors.toSet()));
if (recoveredActions.isEmpty()) {
return;
}
recoveredActions.forEach(this::execute); recoveredActions.forEach(this::execute);
blockManager.emitActionRecoveredBlock(recoveredActions); blockManager.emitActionRecoveredBlock(recoveredActions);
} }