Skip to content

Commit 2d975e1

Browse files
authored
[BugFix] fix TaskQueue dp_id in multi node (#3919)
1 parent 8915c84 commit 2d975e1

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

fastdeploy/engine/common_engine.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,8 @@ def start_worker_queue_service(self, start_queue):
225225
client_id=0,
226226
local_data_parallel_size=self.cfg.parallel_config.data_parallel_size,
227227
local_data_parallel_id=min(
228-
self.cfg.worker_num_per_node * self.cfg.node_rank + self.cfg.parallel_config.local_data_parallel_id,
228+
self.cfg.worker_num_per_node // self.cfg.parallel_config.tensor_parallel_size * self.cfg.node_rank
229+
+ self.cfg.parallel_config.local_data_parallel_id,
229230
self.cfg.parallel_config.data_parallel_size - 1,
230231
),
231232
)

0 commit comments

Comments
 (0)