Parallel Processing

This example demonstrates parallel execution branches joining into a final aggregation stage.

#      Start
#     /  |  \
# Task1 Task2 Task3
#      \  |  /
#       Done

workflow = Workflow.create(
    application="example",
    name="Parallel",
    stages=[
        StageExecution(ref_id="start", ...),
        StageExecution(ref_id="t1", requisite_stage_ref_ids={"start"}, ...),
        StageExecution(ref_id="t2", requisite_stage_ref_ids={"start"}, ...),
        StageExecution(ref_id="t3", requisite_stage_ref_ids={"start"}, ...),
        StageExecution(ref_id="done", requisite_stage_ref_ids={"t1", "t2", "t3"}, ...),
    ]
)

See examples/python-example.py (Example 3) for the full runnable code.