(self)
| 510 | events: dict[tuple[str, int], list[api.SnapshotEvent]] = {} |
| 511 | |
| 512 | def _get_next_unique_name(self) -> str: |
| 513 | return str(f"_stream_generator_{next(self._unique_name)}") |
| 514 | |
| 515 | def _advance_time_for_all_workers( |
| 516 | self, unique_name: str, workers: Iterable[int], timestamp: int |