apps/FastDeploy
1
0
Fork 0
mirror of https://github.com/PaddlePaddle/FastDeploy.git synced 2026-04-23 00:17:25 +08:00
Code Issues Actions 19 Packages Projects Releases Wiki Activity

[BugFix] fix incorrect function parameters of start_data_parallel_service (#6674)

Browse Source
This commit is contained in:
ddchenhao66
2026-03-09 10:15:50 +08:00
committed by GitHub
parent cbfdf42628
commit 3c0ff20328
2 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fastdeploy/engine/expert_service.py
+2 -6
View File
@@ -205,18 +205,14 @@ class ExpertService:
self.zmq_server.close()
def start_data_parallel_service(
cfg, local_data_parallel_id, ipc_signal_suffix=None, request_queues_for_dp_ipc=None, result_queues_for_dp_ipc=None
):
def start_data_parallel_service(cfg, local_data_parallel_id, ipc_signal_suffix=None):
"""
Start expert service
"""
expert_service = ExpertService(cfg, local_data_parallel_id, start_queue=False)
try:
expert_service.start(
ipc_signal_suffix, local_data_parallel_id, request_queues_for_dp_ipc, result_queues_for_dp_ipc
)
expert_service.start(ipc_signal_suffix, local_data_parallel_id)
def deamon_thread():
while True: