Inline Subworkflow Node | Vellum

1 from vellum.workflows.nodes import InlineSubworkflowNode 2 from vellum.workflows.inputs.base import BaseInputs 3 from vellum.workflows.state import BaseState 4 from vellum.workflows import BaseWorkflow 5 6 class SubworkflowInputs(BaseInputs): 7 query: str 8 max_results: int 9 10 class SubworkflowState(BaseState): 11 pass 12 13 class MySubworkflow(BaseWorkflow[SubworkflowInputs, SubworkflowState]): 14 # Define your subworkflow logic here 15 pass 16 17 class MyInlineSubworkflowNode(InlineSubworkflowNode): 18 subworkflow = MySubworkflow 19 subworkflow_inputs = { 20 "query": "search term", 21 "max_results": 10 22 }

1 # Outputs depend on the subworkflow's defined outputs 2 MyInlineSubworkflowNode.Outputs( 3 search_results=["Result 1", "Result 2", "Result 3"], 4 metadata={ 5 "total_found": 100, 6 "processing_time": 0.5 7 } 8 )

vellum.workflows.nodes.InlineSubworkflowNode

Used to execute a Subworkflow defined inline within your workflow. This allows you to modularize and reuse workflow logic.

Attributes

subworkflow

Type[BaseWorkflow[WorkflowInputsType, InnerStateType]]Required

The Subworkflow class to execute

subworkflow_inputs

Dict[str, Any]Required

The inputs to pass to the subworkflow

Outputs

The outputs of this node are determined by the outputs defined in the subworkflow. Each output from the subworkflow will be streamed through this node.