Skip to content

support dist.broadcast#7956

Open
zpcore wants to merge 3 commits intomasterfrom
piz/broadcast
Open

support dist.broadcast#7956
zpcore wants to merge 3 commits intomasterfrom
piz/broadcast

Conversation

@zpcore
Copy link
Copy Markdown
Member

@zpcore zpcore commented Sep 5, 2024

Support torch.distributed.broadcast for both dynamo and nondynamo.

This PR needs pytorch/pytorch#135171 to be merged first.

@zpcore zpcore added usability Bugs/features related to improving the usability of PyTorch/XLA tpuci labels Sep 5, 2024
@zpcore zpcore marked this pull request as ready for review September 5, 2024 02:04
XLATensorPtr xmask = bridge::GetXlaTensor(mask);
auto masked_input = tensor_methods::mul(xinput, xmask);
auto result = tensor_methods::all_reduce(masked_input, AllReduceType::kSum,
1.0, {}, true);
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: name the non-obvious arguments at the end here. Assuming these two are scale and replica groups, /*scale=*/1, /*groups=*/{} (double check the names).



@absltest.skipIf(lambda: tpu.num_logical_cores_per_chip() >= 2,
@absltest.skipIf(tpu.num_logical_cores_per_chip() >= 2,
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🤦 thanks



# "broadcast(Tensor self, int src, str tag, int[] ranks, int group_size) -> Tensor",
@torch.library.impl("_c10d_functional::broadcast", "XLA")
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@JackCaoG FYI

at::Tensor mask;
const torch::lazy::BackendDevice& device = xinput->GetDevice();
if (device.ordinal() == src) {
mask = at::ones_like(input);
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is there an equivalent to torch.no_grad() in C++? That's the only difference I see between the original python version and this one

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Searched the doc and we can use the following scope for tensor operation without grad:

  {
    at::NoGradGuard no_grad;
    // tensor operations
   }

Copy link
Copy Markdown
Member Author

@zpcore zpcore Sep 19, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Anyone knows why we set no grad here:

with torch.no_grad():
@JackCaoG

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

usability Bugs/features related to improving the usability of PyTorch/XLA

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants