Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
BaiXuePrincess
Paddle
提交
fe811625
P
Paddle
项目概览
BaiXuePrincess
/
Paddle
与 Fork 源项目一致
Fork自
PaddlePaddle / Paddle
通知
1
Star
1
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
P
Paddle
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
未验证
提交
fe811625
编写于
2月 09, 2023
作者:
P
pangengzheng
提交者:
GitHub
2月 09, 2023
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Fix pscore test (#50349)
上级
e389f2fc
变更
3
显示空白变更内容
内联
并排
Showing
3 changed file
with
8 addition
and
6 deletion
+8
-6
paddle/fluid/distributed/ps/wrapper/fleet.cc
paddle/fluid/distributed/ps/wrapper/fleet.cc
+2
-0
python/paddle/distributed/ps/the_one_ps.py
python/paddle/distributed/ps/the_one_ps.py
+0
-2
python/paddle/fluid/tests/unittests/ps/CMakeLists.txt
python/paddle/fluid/tests/unittests/ps/CMakeLists.txt
+6
-4
未找到文件。
paddle/fluid/distributed/ps/wrapper/fleet.cc
浏览文件 @
fe811625
...
@@ -129,6 +129,8 @@ void FleetWrapper::InitWorker(const std::string& dist_desc,
...
@@ -129,6 +129,8 @@ void FleetWrapper::InitWorker(const std::string& dist_desc,
paddle
::
distributed
::
PSClientFactory
::
Create
(
ps_param
));
paddle
::
distributed
::
PSClientFactory
::
Create
(
ps_param
));
worker_ptr_
->
Configure
(
ps_param
,
dense_pull_regions
,
ps_env_
,
index
);
worker_ptr_
->
Configure
(
ps_param
,
dense_pull_regions
,
ps_env_
,
index
);
}
}
dist_desc_
=
dist_desc
;
is_initialized_
=
true
;
}
else
{
}
else
{
VLOG
(
3
)
<<
"Client can be initialized only once"
;
VLOG
(
3
)
<<
"Client can be initialized only once"
;
}
}
...
...
python/paddle/distributed/ps/the_one_ps.py
浏览文件 @
fe811625
...
@@ -1171,8 +1171,6 @@ class TheOnePSRuntime(RuntimeBase):
...
@@ -1171,8 +1171,6 @@ class TheOnePSRuntime(RuntimeBase):
gpus_env
=
os
.
getenv
(
"FLAGS_selected_gpus"
)
gpus_env
=
os
.
getenv
(
"FLAGS_selected_gpus"
)
gpus_env
=
[
int
(
s
)
for
s
in
gpus_env
.
split
(
","
)]
gpus_env
=
[
int
(
s
)
for
s
in
gpus_env
.
split
(
","
)]
main_program
.
_fleet_opt
[
"worker_places"
]
=
gpus_env
main_program
.
_fleet_opt
[
"worker_places"
]
=
gpus_env
PSGPU
=
core
.
PSGPU
()
PSGPU
.
init_gpu_ps
(
gpus_env
)
def
sync_strategy_envs
():
def
sync_strategy_envs
():
kwargs
=
{}
kwargs
=
{}
...
...
python/paddle/fluid/tests/unittests/ps/CMakeLists.txt
浏览文件 @
fe811625
...
@@ -4,7 +4,9 @@ file(
...
@@ -4,7 +4,9 @@ file(
"test_*.py"
)
"test_*.py"
)
string
(
REPLACE
".py"
""
TEST_OPS
"
${
TEST_OPS
}
"
)
string
(
REPLACE
".py"
""
TEST_OPS
"
${
TEST_OPS
}
"
)
list
(
REMOVE_ITEM TEST_OPS
"test_gpubox_ps"
)
if
(
NOT WITH_HETERPS OR WITH_PSLIB
)
list
(
REMOVE_ITEM TEST_OPS
"test_gpubox_ps"
)
endif
()
foreach
(
TEST_OP
${
TEST_OPS
}
)
foreach
(
TEST_OP
${
TEST_OPS
}
)
py_test_modules
(
${
TEST_OP
}
MODULES
${
TEST_OP
}
)
py_test_modules
(
${
TEST_OP
}
MODULES
${
TEST_OP
}
)
...
@@ -12,6 +14,6 @@ foreach(TEST_OP ${TEST_OPS})
...
@@ -12,6 +14,6 @@ foreach(TEST_OP ${TEST_OPS})
set_tests_properties
(
${
TEST_OP
}
PROPERTIES TIMEOUT 50
)
set_tests_properties
(
${
TEST_OP
}
PROPERTIES TIMEOUT 50
)
endforeach
()
endforeach
()
#if(WITH_HETERPS
)
if
(
WITH_HETERPS AND NOT WITH_PSLIB
)
#
set_tests_properties(test_gpubox_ps PROPERTIES LABELS "RUN_TYPE=GPUPS")
set_tests_properties
(
test_gpubox_ps PROPERTIES LABELS
"RUN_TYPE=GPUPS"
)
#
endif()
endif
()
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录