Function sg_add

src/WorkFlow.py:130–143

(name:str, state: PipelineState, sg_name: str)

def sg_add(name:str, state: PipelineState, sg_name: str) -> PipelineState:
    logger(f"{name} is working, it is a subgraph node call {sg_name} ...")
    subgraph = subgraph_registry[sg_name]
    response = subgraph.invoke(
        PipelineState(
            history=state["history"],
            task=state["task"],
            condition=state["condition"]
        )
    )
    state["history"] = response["history"]
    state["task"] = response["task"]
    state["condition"] = response["condition"]
    return state


def conditional_edge(state: PipelineState) -> Literal["True", "False"]: