diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/SwitchCondition.java b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/SwitchCondition.java index 05ded2445..07a90df37 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/SwitchCondition.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/element/condition/SwitchCondition.java @@ -185,6 +185,7 @@ public class SwitchCondition extends AbstractParallelCondition { WhenCondition whenCondition = new WhenCondition(); matchedExecutors.forEach(whenCondition::addExecutable); whenCondition.setThreadExecutorClass(this.getThreadPoolExecutorClass()); + whenCondition.setCurrChainId(this.getCurrChainId()); whenCondition.executeCondition(slotIndex); } else { for (Executable targetExecutor : matchedExecutors) {