Skip to content

Commit da44942

Browse files
committed
add comm split support
1 parent 836ed81 commit da44942

File tree

1 file changed

+17
-1
lines changed

1 file changed

+17
-1
lines changed

torch/csrc/distributed/c10d/init.cpp

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3386,15 +3386,31 @@ Example::
33863386
py::arg("rank"),
33873387
py::arg("size"),
33883388
py::arg("options"),
3389-
R"(Create a new ProcessGroupXCCL instance.)");
3389+
R"(Create a new ProcessGroupXCCL instance.)")
3390+
.def(
3391+
"comm_split_count",
3392+
&::c10d::ProcessGroupXCCL::getCommSplitCounter)
3393+
.def_property(
3394+
"bound_device_id",
3395+
&::c10d::ProcessGroupXCCL::getBoundDeviceId,
3396+
&::c10d::ProcessGroupXCCL::setBoundDeviceId,
3397+
R"(Return the bound device id.)")
3398+
.def(
3399+
"perform_nocolor_split",
3400+
&::c10d::ProcessGroupXCCL::performNocolorSplit);
33903401
intrusive_ptr_class_<::c10d::ProcessGroupXCCL::Options>(
33913402
processGroupXCCL,
33923403
"Options",
33933404
backendOptions)
33943405
.def(py::init<bool>(), py::arg("is_high_priority_stream") = false)
3406+
.def_readwrite("config", &::c10d::ProcessGroupXCCL::Options::config)
33953407
.def_readwrite(
33963408
"is_high_priority_stream",
33973409
&::c10d::ProcessGroupXCCL::Options::is_high_priority_stream)
3410+
.def_readwrite(
3411+
"split_from", &::c10d::ProcessGroupXCCL::Options::split_from)
3412+
.def_readwrite(
3413+
"split_color", &::c10d::ProcessGroupXCCL::Options::split_color)
33983414
.def_readwrite(
33993415
"global_ranks_in_group",
34003416
&::c10d::ProcessGroupXCCL::Options::global_ranks_in_group)

0 commit comments

Comments
 (0)