Function invoke_root

src/WorkFlow.py:252–261

(state: MainGraphState)

    input: Union[str, None]

def invoke_root(state: MainGraphState):
    subgraph = subgraph_registry["root"]
    response = subgraph.invoke(
        PipelineState(
            history="",
            task="",
            condition=False
        )
    )
    return  {"input": None}


def run_workflow_as_server(llm):