跳到主要内容

静态并行 Step

Definition graph

StaticParallelStepsFlow

Valid

python · examples/python/dex_examples/patterns/parallel/static_parallel_steps_flow.py

InitStep 同时为 WorkAStep 和 WorkBStep 返回 movement。两个 Step 独立完成，适用于分支职责和输入类型都已知的场景。

核心实现​

起始 Step 在同一个 decision 中返回两个 movement。

class WorkAStep(Step[str]):
    def execute(self, context: Context, input: str) -> StepDecision:
        return graceful_complete(f"A:{input}")


class WorkBStep(Step[str]):
    def execute(self, context: Context, input: str) -> StepDecision:
        return graceful_complete(f"B:{input}")


class InitStep(Step[str]):
    def execute(self, context: Context, input: str) -> StepDecision:
        return go_to_many(
            StepMovement.of(WorkAStep, input),
            StepMovement.of(WorkBStep, input),
        )

例子: examples/python/dex_examples/patterns/parallel/static_parallel_steps_flow.py

相关内容​