Inline Subworkflow Node | Vellum

from vellum.workflows.nodes import InlineSubworkflowNode
from vellum.workflows.inputs.base import BaseInputs
from vellum.workflows.state import BaseState
from vellum.workflows import BaseWorkflow
class SubworkflowInputs(BaseInputs):
    query: str
    max_results: int
class SubworkflowState(BaseState):
    pass
class MySubworkflow(BaseWorkflow[SubworkflowInputs, SubworkflowState]):
    # Define your subworkflow logic here
    pass
class MyInlineSubworkflowNode(InlineSubworkflowNode):
    subworkflow = MySubworkflow
    subworkflow_inputs = {
        "query": "search term",
        "max_results": 10
    }

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

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.

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	)