Fix dp print message (#2138)
This commit is contained in:
@@ -1388,8 +1388,8 @@ def run_scheduler_process(
|
|||||||
pipe_writer,
|
pipe_writer,
|
||||||
):
|
):
|
||||||
# [For Router] if env var "DP_RANK" exist, set dp_rank to the value of the env var
|
# [For Router] if env var "DP_RANK" exist, set dp_rank to the value of the env var
|
||||||
if dp_rank is None:
|
if dp_rank is None and "DP_RANK" in os.environ:
|
||||||
dp_rank = int(os.getenv("DP_RANK", -1))
|
dp_rank = int(os["DP_RANK"])
|
||||||
|
|
||||||
if dp_rank is None:
|
if dp_rank is None:
|
||||||
configure_logger(server_args, prefix=f" TP{tp_rank}")
|
configure_logger(server_args, prefix=f" TP{tp_rank}")
|
||||||
|
|||||||
Reference in New Issue
Block a user