github
/
ColossalAI
mirror of https://github.com/hpcaitech/ColossalAI
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

[gemini] maxprefetch means maximum work to keep

pull/5722/head
hxwang 2024-05-16 16:12:53 +08:00
parent fc2248cf99
commit f45f8a2aa7
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
colossalai/zero/gemini/placement_policy.py
View File

@ -118,14 +118,15 @@ class StaticPlacementPolicy(PlacementPolicy):
def get_prefetch_chunks(self) -> List[Chunk]: def get_prefetch_chunks(self) -> List[Chunk]:
if self.gemini_manager.is_warmup(): # no prefetch during warmup since we need compute_list if self.gemini_manager.is_warmup(): # no prefetch during warmup since we need compute_list
return [] return []
can_prefetch = self.max_prefetch - len(self.gemini_manager._async_works)
prefetch = [] prefetch = []
for i in range(self.gemini_manager.compute_idx + 1, len(self.gemini_manager.compute_list)): for i in range(self.gemini_manager.compute_idx + 1, len(self.gemini_manager.compute_list)):
for chunk in self.gemini_manager.compute_list[i]: for chunk in self.gemini_manager.compute_list[i]:
if len(prefetch) >= self.max_prefetch: if len(prefetch) >= can_prefetch:
break break
if chunk not in prefetch and chunk not in self.chunk_manager.accessed_chunks: if chunk not in prefetch and chunk not in self.chunk_manager.accessed_chunks:
prefetch.append(chunk) prefetch.append(chunk)
if len(prefetch) >= self.max_prefetch: if len(prefetch) >= can_prefetch:
break break
return prefetch return prefetch