Fix memory leak in prefill delayer (#16358)
This commit is contained in:
@@ -1929,10 +1929,10 @@ class Scheduler(
|
|||||||
if self.prefill_delayer
|
if self.prefill_delayer
|
||||||
else True
|
else True
|
||||||
)
|
)
|
||||||
if (not delayer_allow_prefill) or (
|
if (
|
||||||
(self.running_batch.batch_is_full or len(self.waiting_queue) == 0)
|
(not delayer_allow_prefill)
|
||||||
and self.chunked_req is None
|
or ((self.running_batch.batch_is_full or len(self.waiting_queue) == 0))
|
||||||
):
|
) and self.chunked_req is None:
|
||||||
return None
|
return None
|
||||||
|
|
||||||
running_bs = len(self.running_batch.reqs)
|
running_bs = len(self.running_batch.reqs)
|
||||||
|
|||||||
@@ -27,19 +27,14 @@ class TestPrefillDelayerThroughput(CustomTestCase):
|
|||||||
"--dp",
|
"--dp",
|
||||||
"8",
|
"8",
|
||||||
"--chunked-prefill-size",
|
"--chunked-prefill-size",
|
||||||
"262144",
|
"131072",
|
||||||
"--mem-fraction-static",
|
"--mem-fraction-static",
|
||||||
"0.6",
|
"0.6",
|
||||||
]
|
]
|
||||||
|
|
||||||
# TODO further fix mem leak
|
|
||||||
with envs.SGLANG_SCHEDULER_DECREASE_PREFILL_IDLE.override(
|
with envs.SGLANG_SCHEDULER_DECREASE_PREFILL_IDLE.override(
|
||||||
with_prefill_delayer
|
with_prefill_delayer
|
||||||
), envs.SGLANG_PREFILL_DELAYER_MAX_DELAY_PASSES.override(
|
), envs.SGLANG_PREFILL_DELAYER_MAX_DELAY_PASSES.override(100):
|
||||||
100
|
|
||||||
), envs.SGLANG_ENABLE_STRICT_MEM_CHECK_DURING_IDLE.override(
|
|
||||||
False
|
|
||||||
):
|
|
||||||
process = popen_launch_server(
|
process = popen_launch_server(
|
||||||
model,
|
model,
|
||||||
base_url,
|
base_url,
|
||||||
@@ -52,6 +47,7 @@ class TestPrefillDelayerThroughput(CustomTestCase):
|
|||||||
base_url=base_url,
|
base_url=base_url,
|
||||||
dataset_name="random",
|
dataset_name="random",
|
||||||
num_prompts=500,
|
num_prompts=500,
|
||||||
|
# trigger chunked prefill
|
||||||
random_input_len=30000,
|
random_input_len=30000,
|
||||||
random_output_len=256,
|
random_output_len=256,
|
||||||
request_rate=32,
|
request_rate=32,
|
||||||
|
|||||||
Reference in New Issue
Block a user