Method
__init__
(self, *, source_worker: str = "local-training", source_rank: int = 0)
Source from the content-addressed store, hash-verified
| 1706 | transport = "shared-memory" |
| 1707 | |
| 1708 | def __init__(self, *, source_worker: str = "local-training", source_rank: int = 0): |
| 1709 | super().__init__(source_worker=source_worker, source_rank=source_rank) |
| 1710 | self._shared_memory_segments: dict[str, dict[str, shared_memory.SharedMemory]] = {} |
| 1711 | self._owned_shared_memory_update_ids: set[str] = set() |
| 1712 | |
| 1713 | def publish( |
| 1714 | self, |
Callers
nothing calls this directly
Tested by
no test coverage detected