These 1 commits are when the Protocol Buffers files have changed:
| Commit: | 17e61e5 | |
|---|---|---|
| Author: | Xianyang Liu | |
| Committer: | GitHub | |
[mpi-part1] running mpi job on ray (#115) - [x] openmpi support - [x] intel mpi support - [ ] mpich support # for tests - [ ] add UT tests - [ ] add examples - [ ] add doc ```python In [1]: import ray In [2]: ray.init() 2021-04-10 10:48:47,466 INFO services.py:1174 -- View the Ray dashboard at http://127.0.0.1:8265 Out[2]: {'node_ip_address': '10.239.10.106', 'raylet_ip_address': '10.239.10.106', 'redis_address': '10.239.10.106:6379', 'object_store_address': '/tmp/ray/session_2021-04-10_10-48-46_992240_3603/sockets/plasma_store', 'raylet_socket_name': '/tmp/ray/session_2021-04-10_10-48-46_992240_3603/sockets/raylet', 'webui_url': '127.0.0.1:8265', 'session_dir': '/tmp/ray/session_2021-04-10_10-48-46_992240_3603', 'metrics_export_port': 54124, 'node_id': '7015de48637c3d929913cc0ed1eb4a7b43cd3a2eaa0808f228d4381d'} In [3]: from raydp.mpi import create_mpi_job In [4]: job = create_mpi_job("test", 1, 2, 1, None, mpi_type="openmpi") In [5]: job.start() [1,0]<stderr>:2021-04-10 10:49:01,313 INFO worker.py:655 -- Connecting to existing Ray cluster at address: 10.239.10.106:6379 In [6]: def f(context): ...: return context.world_rank ...: In [7]: job.run(f) Out[7]: [0] In [8]: job.stop() ```
The documentation is generated from this commit.