Fix lint on main (#19054)
This commit is contained in:
@@ -11,7 +11,7 @@ from dataclasses import asdict, dataclass, fields, replace
|
|||||||
from functools import cached_property
|
from functools import cached_property
|
||||||
from http.server import BaseHTTPRequestHandler, HTTPServer
|
from http.server import BaseHTTPRequestHandler, HTTPServer
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from typing import Any, List, Literal, Optional, Self, Union, get_args, get_type_hints
|
from typing import Any, List, Literal, Optional, Union, get_args, get_type_hints
|
||||||
|
|
||||||
import torch
|
import torch
|
||||||
import torch.distributed as dist
|
import torch.distributed as dist
|
||||||
@@ -47,7 +47,7 @@ class _FrozenConfig(ABC):
|
|||||||
return f"{cls._env_prefix()}{field_name.upper()}"
|
return f"{cls._env_prefix()}{field_name.upper()}"
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def from_env(cls) -> Self:
|
def from_env(cls) -> "_FrozenConfig":
|
||||||
return cls(
|
return cls(
|
||||||
**{
|
**{
|
||||||
f.name: cls._parse_env_field(cls._env_name(f.name), f.default)
|
f.name: cls._parse_env_field(cls._env_name(f.name), f.default)
|
||||||
@@ -55,7 +55,7 @@ class _FrozenConfig(ABC):
|
|||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
def with_defaults(self, **kwargs) -> Self:
|
def with_defaults(self, **kwargs) -> "_FrozenConfig":
|
||||||
cls = type(self)
|
cls = type(self)
|
||||||
actual = {
|
actual = {
|
||||||
key: value
|
key: value
|
||||||
|
|||||||
@@ -35,7 +35,6 @@ from torch.distributed import barrier
|
|||||||
|
|
||||||
from sglang.srt.configs.model_config import ModelConfig
|
from sglang.srt.configs.model_config import ModelConfig
|
||||||
from sglang.srt.constrained.grammar_manager import GrammarManager
|
from sglang.srt.constrained.grammar_manager import GrammarManager
|
||||||
from sglang.srt.debug_utils.dumper import dumper
|
|
||||||
from sglang.srt.disaggregation.decode import (
|
from sglang.srt.disaggregation.decode import (
|
||||||
DecodePreallocQueue,
|
DecodePreallocQueue,
|
||||||
DecodeTransferQueue,
|
DecodeTransferQueue,
|
||||||
@@ -2965,6 +2964,8 @@ class Scheduler(
|
|||||||
return None
|
return None
|
||||||
|
|
||||||
def handle_dumper_control(self, recv_req: DumperControlReqInput):
|
def handle_dumper_control(self, recv_req: DumperControlReqInput):
|
||||||
|
from sglang.srt.debug_utils.dumper import dumper
|
||||||
|
|
||||||
try:
|
try:
|
||||||
response: list = []
|
response: list = []
|
||||||
if (
|
if (
|
||||||
|
|||||||
Reference in New Issue
Block a user