__init__.py 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. from ray.util.collective.collective import (
  2. allgather,
  3. allgather_multigpu,
  4. allreduce,
  5. allreduce_multigpu,
  6. barrier,
  7. broadcast,
  8. broadcast_multigpu,
  9. create_collective_group,
  10. destroy_collective_group,
  11. get_collective_group_size,
  12. get_group_handle,
  13. get_rank,
  14. gloo_available,
  15. init_collective_group,
  16. is_group_initialized,
  17. nccl_available,
  18. recv,
  19. recv_multigpu,
  20. reduce,
  21. reduce_multigpu,
  22. reducescatter,
  23. reducescatter_multigpu,
  24. send,
  25. send_multigpu,
  26. )
  27. __all__ = [
  28. "nccl_available",
  29. "gloo_available",
  30. "is_group_initialized",
  31. "init_collective_group",
  32. "destroy_collective_group",
  33. "create_collective_group",
  34. "get_rank",
  35. "get_collective_group_size",
  36. "allreduce",
  37. "allreduce_multigpu",
  38. "barrier",
  39. "reduce",
  40. "reduce_multigpu",
  41. "broadcast",
  42. "broadcast_multigpu",
  43. "allgather",
  44. "allgather_multigpu",
  45. "reducescatter",
  46. "reducescatter_multigpu",
  47. "send",
  48. "send_multigpu",
  49. "recv",
  50. "recv_multigpu",
  51. "get_group_handle",
  52. ]