[chore] fix init error

pull/5738/head
hxwang 2024-05-21 02:07:21 +00:00
parent f5b7de38a4
commit 137a7c341b
1 changed files with 1 additions and 1 deletions

View File

@ -42,7 +42,7 @@ class GeminiManager:
self._mem_stats_collector = (
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_idx: int = -1
self._async_works: Dict[Chunk, dist.Work] = {}