|
|
@ -42,7 +42,9 @@ class GeminiManager: |
|
|
|
self._mem_stats_collector = ( |
|
|
|
self._mem_stats_collector = ( |
|
|
|
ChunkMemStatsCollector(chunk_manager, self._memstats) if policy_cls.need_mem_stats else None |
|
|
|
ChunkMemStatsCollector(chunk_manager, self._memstats) if policy_cls.need_mem_stats else None |
|
|
|
) |
|
|
|
) |
|
|
|
self._placement_policy = policy_cls(self, chunk_manager, self._mem_stats_collector, **placement_kwargs) |
|
|
|
self._placement_policy = policy_cls( |
|
|
|
|
|
|
|
chunk_manager=chunk_manager, mem_stats_collector=self._mem_stats_collector, **placement_kwargs |
|
|
|
|
|
|
|
) |
|
|
|
self._compute_list: List[Tuple[Chunk, ...]] = [] |
|
|
|
self._compute_list: List[Tuple[Chunk, ...]] = [] |
|
|
|
self._compute_idx: int = -1 |
|
|
|
self._compute_idx: int = -1 |
|
|
|
self._async_works: Dict[Chunk, dist.Work] = {} |
|
|
|
self._async_works: Dict[Chunk, dist.Work] = {} |
|
|
|