refactor(codespell): corrects typos covered up by whitelist (#17601)
This commit is contained in:
@@ -16,7 +16,7 @@ from sglang.srt.server_args import ServerArgs
|
||||
def start_disagg_service(
|
||||
server_args: ServerArgs,
|
||||
):
|
||||
# Start kv boostrap server on prefill
|
||||
# Start kv bootstrap server on prefill
|
||||
disagg_mode = DisaggregationMode(server_args.disaggregation_mode)
|
||||
transfer_backend = TransferBackend(server_args.disaggregation_transfer_backend)
|
||||
|
||||
|
||||
@@ -354,9 +354,9 @@ class SchedulePolicy:
|
||||
last_node_to_reqs: Dict[TreeNode, List[Req]],
|
||||
q: List,
|
||||
) -> None:
|
||||
childs = [child for child in cur_node.children.values()]
|
||||
childs.sort(key=lambda x: -node_to_priority[x])
|
||||
for child in childs:
|
||||
children = [child for child in cur_node.children.values()]
|
||||
children.sort(key=lambda x: -node_to_priority[x])
|
||||
for child in children:
|
||||
SchedulePolicy._get_dfs_priority(
|
||||
child, node_to_priority, last_node_to_reqs, q
|
||||
)
|
||||
|
||||
@@ -1481,7 +1481,7 @@ class Scheduler(
|
||||
if recv_req.bootstrap_room is None:
|
||||
error_msg = (
|
||||
f"Invalid request: Disaggregated request received without "
|
||||
f"boostrap room id. {req.rid=}"
|
||||
f"bootstrap room id. {req.rid=}"
|
||||
)
|
||||
logger.error(error_msg)
|
||||
prepare_abort(req, error_msg, status_code=HTTPStatus.BAD_REQUEST)
|
||||
|
||||
@@ -23,21 +23,21 @@ class SessionReqNode:
|
||||
self,
|
||||
req: Req,
|
||||
parent: Optional["SessionReqNode"] = None,
|
||||
childs=None,
|
||||
children=None,
|
||||
):
|
||||
self.req = req
|
||||
self.parent = parent
|
||||
if parent is not None:
|
||||
parent.childs.append(self)
|
||||
self.childs = [] if not childs else childs
|
||||
parent.children.append(self)
|
||||
self.children = [] if not children else children
|
||||
|
||||
def clear_childs(self, req_dict):
|
||||
for req_node in self.childs:
|
||||
def clear_children(self, req_dict):
|
||||
for req_node in self.children:
|
||||
req_node.clear(req_dict)
|
||||
self.childs = []
|
||||
self.children = []
|
||||
|
||||
def clear(self, req_dict):
|
||||
for req_node in self.childs:
|
||||
for req_node in self.children:
|
||||
req_node.clear(req_dict)
|
||||
|
||||
if self.req.finished_reason is None:
|
||||
@@ -52,13 +52,13 @@ class SessionReqNode:
|
||||
return self._str_helper(self.req.rid)
|
||||
|
||||
def _str_helper(self, prefix=""):
|
||||
if len(self.childs) == 0:
|
||||
if len(self.children) == 0:
|
||||
return prefix + "\n"
|
||||
else:
|
||||
origin_prefix = prefix
|
||||
prefix += " -- " + self.childs[0].req.rid
|
||||
ret = self.childs[0]._str_helper(prefix)
|
||||
for child in self.childs[1:]:
|
||||
prefix += " -- " + self.children[0].req.rid
|
||||
ret = self.children[0]._str_helper(prefix)
|
||||
for child in self.children[1:]:
|
||||
prefix = " " * len(origin_prefix) + " \\- " + child.req.rid
|
||||
ret += child._str_helper(prefix)
|
||||
return ret
|
||||
@@ -88,7 +88,7 @@ class Session:
|
||||
last_req_node = self.req_nodes[session_params.rid]
|
||||
last_req_node.abort()
|
||||
last_req = last_req_node.req
|
||||
last_req_node.clear_childs(self.req_nodes)
|
||||
last_req_node.clear_children(self.req_nodes)
|
||||
else:
|
||||
if session_params.rid is not None:
|
||||
if session_params.rid not in self.req_nodes:
|
||||
|
||||
Reference in New Issue
Block a user