dataflow/connection.py

from __future__ import annotations
from dataclasses import dataclass
from .nodes_base import NodeInstance
from .ports import PortState


@dataclass(slots=True, frozen=True)
class Connection:
    start_node: NodeInstance
    start_port: PortState
    end_node: NodeInstance
    end_port: PortState