Function _materialize_node

masfactory/compatibility/langflow/materialize.py:159–187

(
    owner: OwnerGraph,
    ext,
    options: LangflowCompileOptions,
    *,
    graph_name: str,
)

def _materialize_node(
    owner: OwnerGraph,
    ext,
    options: LangflowCompileOptions,
    *,
    graph_name: str,
) -> Node:
    kind = ext.kind
    if kind in CHAT_INPUT_KINDS:
        forward = _make_chat_input_forward(ext.id, ext, owner)
    elif kind in CHAT_OUTPUT_KINDS:
        forward = _make_chat_output_forward(ext.id, owner)
    elif kind in PROMPT_KINDS:
        forward = _make_prompt_forward(ext.id, ext, owner)
    elif kind in LLM_KINDS:
        forward = _make_llm_forward(ext.id, ext, owner, options)
    else:
        forward = _make_passthrough_forward(ext.id, owner)

    return owner.create_node(
        CustomNode,
        name=graph_name,
        forward=forward,
        attributes={
            "langflow_id": ext.id,
            "langflow_kind": kind,
            "langflow_label": ext.label,
        },
    )


def _wire_subgraph(