Method flow_edge_send

masfactory/visualizer/runtime.py:448–492

Record an edge-send flow event. Args: sender: Sender node. receiver: Receiver node. edge_keys: Optional edge key mapping (used to render key labels/details). message: Optional message payload snapshot.

(
        self,
        sender: object,
        receiver: object,
        *,
        edge_keys: dict[str, object] | None = None,
        message: dict[str, object] | None = None,
    )

            self._record_history(payload)

    def flow_edge_send(
        self,
        sender: object,
        receiver: object,
        *,
        edge_keys: dict[str, object] | None = None,
        message: dict[str, object] | None = None,
    ) -> None:
        """Record an edge-send flow event.

        Args:
            sender: Sender node.
            receiver: Receiver node.
            edge_keys: Optional edge key mapping (used to render key labels/details).
            message: Optional message payload snapshot.
        """
        sender_id = self._resolve_node_id(sender)
        receiver_id = self._resolve_node_id(receiver)
        if not sender_id or not receiver_id:
            return

        keys: list[str] = []
        keys_details: dict[str, object] | None = None
        if isinstance(edge_keys, dict):
            keys = [str(k) for k in edge_keys.keys()]
            keys_details = {str(k): edge_keys.get(k) for k in edge_keys.keys()}

        payload: dict[str, object] = {
            "type": "FLOW",
            "kind": "EDGE_SEND",
            "ts": _now_ms(),
            "from": sender_id,
            "to": receiver_id,
        }
        if keys:
            payload["keys"] = keys
        if keys_details:
            payload["keysDetails"] = self._safe_for_history(keys_details)
        if isinstance(message, dict) and message:
            payload["message"] = self._safe_for_history(message)

        if self.is_streaming():
            self._enqueue(payload)
        else:
            self._record_history(payload)

    def flow_attr_pull(
        self,