File tree Expand file tree Collapse file tree 2 files changed +5
-6
lines changed Expand file tree Collapse file tree 2 files changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -1553,11 +1553,12 @@ def create_engine_config(
15531553 )
15541554
15551555 if self .async_scheduling and (
1556- parallel_config .distributed_executor_backend not in ("mp" , "uni" )
1556+ parallel_config .distributed_executor_backend
1557+ not in ("mp" , "uni" , "external_launcher" )
15571558 ):
15581559 raise ValueError (
1559- "Currently, async scheduling only supports `mp` or `uni` "
1560- "distributed executor backend, but you choose "
1560+ "Currently, async scheduling only supports `mp`, `uni` or "
1561+ "`external_launcher` distributed executor backend, but you choose "
15611562 f"`{ parallel_config .distributed_executor_backend } `."
15621563 )
15631564
Original file line number Diff line number Diff line change @@ -306,9 +306,7 @@ def step(self) -> list[RequestOutput] | list[PoolingRequestOutput]:
306306 self .engine_core .abort_requests (processed_outputs .reqs_to_abort )
307307
308308 # 4) Record stats
309- if self .logger_manager is not None :
310- assert outputs .scheduler_stats is not None
311-
309+ if self .logger_manager is not None and outputs .scheduler_stats is not None :
312310 self .logger_manager .record (
313311 scheduler_stats = outputs .scheduler_stats ,
314312 iteration_stats = iteration_stats ,
You can’t perform that action at this time.
0 commit comments