Function _materialize_node

masfactory/compatibility/chatdev/materialize.py:177–210

(
    owner: OwnerGraph,
    ext,
    options: ChatDevCompileOptions,
    id_to_graph_name: dict[str, str],
)

def _materialize_node(
    owner: OwnerGraph,
    ext,
    options: ChatDevCompileOptions,
    id_to_graph_name: dict[str, str],
) -> Node:
    gname = id_to_graph_name[ext.id]
    attrs = {"chatdev_id": ext.id, "chatdev_label": ext.label, "chatdev_kind": ext.kind}
    cfg = _node_config(ext)
    kind = ext.kind

    if kind == "agent":
        forward = _make_agent_forward(ext.id, cfg, owner, options)
    elif kind == "literal":
        forward = _make_literal_forward(ext.id, cfg, owner)
    elif kind == "loop_counter":
        forward = _make_loop_counter_forward(ext.id, cfg, owner)
    elif kind in {"SimplePhase", "ComposedPhase"}:
        forward = _make_chain_phase_forward(ext.id, ext.raw or {}, owner)
    elif kind == "majority_vote":
        raw = ext.raw or {}
        voters = raw.get("voter_ids") if isinstance(raw.get("voter_ids"), list) else []
        forward = _make_majority_vote_forward(ext.id, [str(v) for v in voters], owner)
    else:
        forward = _make_passthrough_forward(ext.id, owner)

    return owner.create_node(
        CustomNode,
        name=gname,
        forward=forward,
        pull_keys=None,
        push_keys=None,
        attributes=attrs,
    )


def _make_route_predicates(