Skip to content

Commit dcd3e12

Browse files
committed
no replica rank only pid
1 parent 99ecff5 commit dcd3e12

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

verl/workers/rollout/sglang_rollout/async_sglang_server.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ def __init__(
127127
if self.node_rank == 0:
128128
self._master_address = self._server_address
129129
# Seed with replica_rank + pid to avoid port conflicts across replicas and restarts
130-
self._master_port = get_free_port(self._server_address, random_seed=self.replica_rank + os.getpid())
130+
self._master_port = get_free_port(self._server_address, random_seed=os.getpid())
131131
logger.info(
132132
f"SGLangHttpServer, replica_rank: {self.replica_rank}, "
133133
f"master address: {self._master_address}, port: {self._master_port}"

verl/workers/rollout/vllm_rollout/vllm_async_server.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ def __init__(
152152
# used for data parallel: --data-parallel-address, --data-parallel-rpc-port
153153
if self.node_rank == 0:
154154
self._master_address = self._server_address
155-
random_seed = self.replica_rank + os.getpid()
155+
random_seed = os.getpid()
156156
# used for torch.distributed.init_process_group
157157
self._master_port = get_free_port(self._server_address, random_seed=random_seed)
158158
# used for data parallel: --data-parallel-address, --data-parallel-rpc-port

0 commit comments

Comments
 (0)