(self, node: object)
| 315 | self.start() |
| 316 | |
| 317 | def _resolve_node_id(self, node: object) -> str | None: |
| 318 | if node is None: |
| 319 | return None |
| 320 | with self._lock: |
| 321 | if self._root_entry_obj is not None and node is self._root_entry_obj: |
| 322 | return "entry" |
| 323 | if self._root_exit_obj is not None and node is self._root_exit_obj: |
| 324 | return "exit" |
| 325 | name = getattr(node, "name", None) |
| 326 | if isinstance(name, str) and name: |
| 327 | return name |
| 328 | return None |
| 329 | |
| 330 | def node_start(self, node: object, inputs: dict[str, object]) -> _NodeRunContext | None: |
| 331 | """Record a node-start event. |
no outgoing calls
no test coverage detected