fix all2all example (#347)

DefTruth · web-flow · commit 8c5464d26c8d · 2025-06-27T22:04:50.000+08:00
diff --git a/others/pytorch/distributed/test_all_to_all_single_ray.py b/others/pytorch/distributed/test_all_to_all_single_ray.py
@@ -129,7 +129,4 @@ def run(self) -> torch.Tensor:
     ]
     results = ray.get([worker.run.remote() for worker in workers])
     ray.shutdown()
-    if dist.is_initialized():
-        dist.destroy_process_group()
-        print("Process group destroyed")
     print("All processes completed successfully")

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,4 @@ def run(self) -> torch.Tensor:`
`129`	`129`	`]`
`130`	`130`	`results = ray.get([worker.run.remote() for worker in workers])`
`131`	`131`	`ray.shutdown()`
`132`		`- if dist.is_initialized():`
`133`		`- dist.destroy_process_group()`
`134`		`- print("Process group destroyed")`
`135`	`132`	`print("All processes completed successfully")`