[RL]: Fix error tagging in multi-stage wake up (#7812)
Co-authored-by: hebiao064 <hebiaobuaa@gmail.com>
This commit is contained in:
@@ -2333,9 +2333,8 @@ class Scheduler(
|
|||||||
|
|
||||||
def release_memory_occupation(self, recv_req: ReleaseMemoryOccupationReqInput):
|
def release_memory_occupation(self, recv_req: ReleaseMemoryOccupationReqInput):
|
||||||
tags = recv_req.tags
|
tags = recv_req.tags
|
||||||
import subprocess
|
|
||||||
|
|
||||||
if tags is None:
|
if tags is None or len(tags) == 0:
|
||||||
tags = [GPU_MEMORY_TYPE_WEIGHTS, GPU_MEMORY_TYPE_KV_CACHE]
|
tags = [GPU_MEMORY_TYPE_WEIGHTS, GPU_MEMORY_TYPE_KV_CACHE]
|
||||||
|
|
||||||
if GPU_MEMORY_TYPE_KV_CACHE in tags:
|
if GPU_MEMORY_TYPE_KV_CACHE in tags:
|
||||||
@@ -2353,6 +2352,7 @@ class Scheduler(
|
|||||||
|
|
||||||
def resume_memory_occupation(self, recv_req: ResumeMemoryOccupationReqInput):
|
def resume_memory_occupation(self, recv_req: ResumeMemoryOccupationReqInput):
|
||||||
tags = recv_req.tags
|
tags = recv_req.tags
|
||||||
|
|
||||||
if tags is None or len(tags) == 0:
|
if tags is None or len(tags) == 0:
|
||||||
tags = [GPU_MEMORY_TYPE_WEIGHTS, GPU_MEMORY_TYPE_KV_CACHE]
|
tags = [GPU_MEMORY_TYPE_WEIGHTS, GPU_MEMORY_TYPE_KV_CACHE]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user