Skip to content

builder

builder

WorkflowBuilder — fluent API for constructing workflows.

Classes

WorkflowBuilder 

WorkflowBuilder(name: str = '')

Fluent API for building workflow graphs.

Example: wf = (WorkflowBuilder("research_pipeline") .add_agent("researcher", agent="orchestrator", tools=["web_search"]) .add_agent("summarizer", agent="simple") .connect("researcher", "summarizer") .build())

Source code in src/openjarvis/workflow/builder.py 
22
23
24
25
def __init__(self, name: str = "") -> None:
    self._name = name
    self._nodes: List[WorkflowNode] = []
    self._edges: List[WorkflowEdge] = []
Functions
sequential 
sequential(*node_ids: str) -> WorkflowBuilder

Connect nodes in sequential order.

Source code in src/openjarvis/workflow/builder.py 
113
114
115
116
117
118
119
def sequential(self, *node_ids: str) -> WorkflowBuilder:
    """Connect nodes in sequential order."""
    for i in range(len(node_ids) - 1):
        self._edges.append(WorkflowEdge(
            source=node_ids[i], target=node_ids[i + 1],
        ))
    return self