| 838 | b: int |
| 839 | |
| 840 | class InputSubject(pw.io.python.ConnectorSubject): |
| 841 | data: list[dict[str, int]] |
| 842 | |
| 843 | def __init__(self, data: list[dict[str, int]]) -> None: |
| 844 | super().__init__() |
| 845 | self.data = data |
| 846 | |
| 847 | def run(self) -> None: |
| 848 | for entry in self.data: |
| 849 | self.next(**entry) |
| 850 | |
| 851 | @property |
| 852 | def _session_type(self) -> SessionType: |
| 853 | return SessionType.UPSERT |
| 854 | |
| 855 | def run_computation(inputs: list[dict[str, int]], expected: set[str]): |
| 856 | G.clear() |
no outgoing calls