Super tiny fix expert distribution dump error (#12271)
This commit is contained in:
@@ -20,6 +20,7 @@ import time
|
|||||||
from abc import ABC
|
from abc import ABC
|
||||||
from collections import deque
|
from collections import deque
|
||||||
from contextlib import contextmanager
|
from contextlib import contextmanager
|
||||||
|
from pathlib import Path
|
||||||
from typing import TYPE_CHECKING, Any, Dict, List, Literal, Optional, Tuple, Type
|
from typing import TYPE_CHECKING, Any, Dict, List, Literal, Optional, Tuple, Type
|
||||||
|
|
||||||
import einops
|
import einops
|
||||||
@@ -868,7 +869,7 @@ class _StatAccumulator(_UtilizationRateAccumulatorMixin):
|
|||||||
|
|
||||||
|
|
||||||
def _dump_to_file(name, data):
|
def _dump_to_file(name, data):
|
||||||
save_dir = envs.SGLANG_EXPERT_DISTRIBUTION_RECORDER_DIR.get()
|
save_dir = Path(envs.SGLANG_EXPERT_DISTRIBUTION_RECORDER_DIR.get())
|
||||||
path_output = save_dir / name
|
path_output = save_dir / name
|
||||||
logger.info(f"Write expert distribution to {path_output}")
|
logger.info(f"Write expert distribution to {path_output}")
|
||||||
if not save_dir.exists():
|
if not save_dir.exists():
|
||||||
|
|||||||
Reference in New Issue
Block a user