|
2 | 2 | "cells": [
|
3 | 3 | {
|
4 | 4 | "cell_type": "code",
|
5 |
| - "execution_count": 1, |
| 5 | + "execution_count": null, |
6 | 6 | "id": "9a44568b-61ef-41c7-8ad1-9a3b128f03a7",
|
7 | 7 | "metadata": {
|
8 | 8 | "tags": []
|
|
69 | 69 | },
|
70 | 70 | {
|
71 | 71 | "cell_type": "code",
|
72 |
| - "execution_count": 3, |
| 72 | + "execution_count": null, |
73 | 73 | "id": "69968140-15e6-482f-9529-82b0cd19524b",
|
74 | 74 | "metadata": {
|
75 | 75 | "tags": []
|
|
81 | 81 | },
|
82 | 82 | {
|
83 | 83 | "cell_type": "code",
|
84 |
| - "execution_count": 4, |
| 84 | + "execution_count": null, |
85 | 85 | "id": "e20f9982-f671-460b-8c22-3d62e101fed9",
|
86 | 86 | "metadata": {
|
87 | 87 | "tags": []
|
88 | 88 | },
|
89 |
| - "outputs": [ |
90 |
| - { |
91 |
| - "name": "stdout", |
92 |
| - "output_type": "stream", |
93 |
| - "text": [ |
94 |
| - "Waiting for requested resources to be set up...\n", |
95 |
| - "Requested cluster up and running!\n" |
96 |
| - ] |
97 |
| - } |
98 |
| - ], |
| 89 | + "outputs": [], |
99 | 90 | "source": [
|
100 | 91 | "cluster.wait_ready()"
|
101 | 92 | ]
|
|
123 | 114 | },
|
124 | 115 | {
|
125 | 116 | "cell_type": "code",
|
126 |
| - "execution_count": 6, |
| 117 | + "execution_count": null, |
127 | 118 | "id": "9483bb98-33b3-4beb-9b15-163d7e76c1d7",
|
128 | 119 | "metadata": {
|
129 |
| - "scrolled": true, |
130 | 120 | "tags": []
|
131 | 121 | },
|
132 |
| - "outputs": [ |
133 |
| - { |
134 |
| - "name": "stderr", |
135 |
| - "output_type": "stream", |
136 |
| - "text": [ |
137 |
| - "2023-06-27 19:14:16,088\tINFO client_builder.py:251 -- Passing the following kwargs to ray.init() on the server: logging_level\n", |
138 |
| - "2023-06-27 19:14:16,100\tDEBUG worker.py:378 -- client gRPC channel state change: ChannelConnectivity.IDLE\n", |
139 |
| - "2023-06-27 19:14:16,308\tDEBUG worker.py:378 -- client gRPC channel state change: ChannelConnectivity.CONNECTING\n", |
140 |
| - "2023-06-27 19:14:16,434\tDEBUG worker.py:378 -- client gRPC channel state change: ChannelConnectivity.READY\n", |
141 |
| - "2023-06-27 19:14:16,436\tDEBUG worker.py:807 -- Pinging server.\n", |
142 |
| - "2023-06-27 19:14:18,634\tDEBUG worker.py:640 -- Retaining 00ffffffffffffffffffffffffffffffffffffff0100000001000000\n", |
143 |
| - "2023-06-27 19:14:18,635\tDEBUG worker.py:564 -- Scheduling task get_dashboard_url 0 b'\\x00\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00'\n", |
144 |
| - "2023-06-27 19:14:18,645\tDEBUG worker.py:640 -- Retaining c8ef45ccd0112571ffffffffffffffffffffffff0100000001000000\n", |
145 |
| - "2023-06-27 19:14:19,454\tDEBUG worker.py:636 -- Releasing c8ef45ccd0112571ffffffffffffffffffffffff0100000001000000\n" |
146 |
| - ] |
147 |
| - }, |
148 |
| - { |
149 |
| - "data": { |
150 |
| - "text/html": [ |
151 |
| - "<div>\n", |
152 |
| - " <div style=\"margin-left: 50px;display: flex;flex-direction: row;align-items: center\">\n", |
153 |
| - " <h3 style=\"color: var(--jp-ui-font-color0)\">Ray</h3>\n", |
154 |
| - " <svg version=\"1.1\" id=\"ray\" width=\"3em\" viewBox=\"0 0 144.5 144.6\" style=\"margin-left: 3em;margin-right: 3em\">\n", |
155 |
| - " <g id=\"layer-1\">\n", |
156 |
| - " <path fill=\"#00a2e9\" class=\"st0\" d=\"M97.3,77.2c-3.8-1.1-6.2,0.9-8.3,5.1c-3.5,6.8-9.9,9.9-17.4,9.6S58,88.1,54.8,81.2c-1.4-3-3-4-6.3-4.1\n", |
157 |
| - " c-5.6-0.1-9.9,0.1-13.1,6.4c-3.8,7.6-13.6,10.2-21.8,7.6C5.2,88.4-0.4,80.5,0,71.7c0.1-8.4,5.7-15.8,13.8-18.2\n", |
158 |
| - " c8.4-2.6,17.5,0.7,22.3,8c1.3,1.9,1.3,5.2,3.6,5.6c3.9,0.6,8,0.2,12,0.2c1.8,0,1.9-1.6,2.4-2.8c3.5-7.8,9.7-11.8,18-11.9\n", |
159 |
| - " c8.2-0.1,14.4,3.9,17.8,11.4c1.3,2.8,2.9,3.6,5.7,3.3c1-0.1,2,0.1,3,0c2.8-0.5,6.4,1.7,8.1-2.7s-2.3-5.5-4.1-7.5\n", |
160 |
| - " c-5.1-5.7-10.9-10.8-16.1-16.3C84,38,81.9,37.1,78,38.3C66.7,42,56.2,35.7,53,24.1C50.3,14,57.3,2.8,67.7,0.5\n", |
161 |
| - " C78.4-2,89,4.7,91.5,15.3c0.1,0.3,0.1,0.5,0.2,0.8c0.7,3.4,0.7,6.9-0.8,9.8c-1.7,3.2-0.8,5,1.5,7.2c6.7,6.5,13.3,13,19.8,19.7\n", |
162 |
| - " c1.8,1.8,3,2.1,5.5,1.2c9.1-3.4,17.9-0.6,23.4,7c4.8,6.9,4.6,16.1-0.4,22.9c-5.4,7.2-14.2,9.9-23.1,6.5c-2.3-0.9-3.5-0.6-5.1,1.1\n", |
163 |
| - " c-6.7,6.9-13.6,13.7-20.5,20.4c-1.8,1.8-2.5,3.2-1.4,5.9c3.5,8.7,0.3,18.6-7.7,23.6c-7.9,5-18.2,3.8-24.8-2.9\n", |
164 |
| - " c-6.4-6.4-7.4-16.2-2.5-24.3c4.9-7.8,14.5-11,23.1-7.8c3,1.1,4.7,0.5,6.9-1.7C91.7,98.4,98,92.3,104.2,86c1.6-1.6,4.1-2.7,2.6-6.2\n", |
165 |
| - " c-1.4-3.3-3.8-2.5-6.2-2.6C99.8,77.2,98.9,77.2,97.3,77.2z M72.1,29.7c5.5,0.1,9.9-4.3,10-9.8c0-0.1,0-0.2,0-0.3\n", |
166 |
| - " C81.8,14,77,9.8,71.5,10.2c-5,0.3-9,4.2-9.3,9.2c-0.2,5.5,4,10.1,9.5,10.3C71.8,29.7,72,29.7,72.1,29.7z M72.3,62.3\n", |
167 |
| - " c-5.4-0.1-9.9,4.2-10.1,9.7c0,0.2,0,0.3,0,0.5c0.2,5.4,4.5,9.7,9.9,10c5.1,0.1,9.9-4.7,10.1-9.8c0.2-5.5-4-10-9.5-10.3\n", |
168 |
| - " C72.6,62.3,72.4,62.3,72.3,62.3z M115,72.5c0.1,5.4,4.5,9.7,9.8,9.9c5.6-0.2,10-4.8,10-10.4c-0.2-5.4-4.6-9.7-10-9.7\n", |
169 |
| - " c-5.3-0.1-9.8,4.2-9.9,9.5C115,72.1,115,72.3,115,72.5z M19.5,62.3c-5.4,0.1-9.8,4.4-10,9.8c-0.1,5.1,5.2,10.4,10.2,10.3\n", |
170 |
| - " c5.6-0.2,10-4.9,9.8-10.5c-0.1-5.4-4.5-9.7-9.9-9.6C19.6,62.3,19.5,62.3,19.5,62.3z M71.8,134.6c5.9,0.2,10.3-3.9,10.4-9.6\n", |
171 |
| - " c0.5-5.5-3.6-10.4-9.1-10.8c-5.5-0.5-10.4,3.6-10.8,9.1c0,0.5,0,0.9,0,1.4c-0.2,5.3,4,9.8,9.3,10\n", |
172 |
| - " C71.6,134.6,71.7,134.6,71.8,134.6z\"/>\n", |
173 |
| - " </g>\n", |
174 |
| - " </svg>\n", |
175 |
| - " <table>\n", |
176 |
| - " <tr>\n", |
177 |
| - " <td style=\"text-align: left\"><b>Python version:</b></td>\n", |
178 |
| - " <td style=\"text-align: left\"><b>3.8.13</b></td>\n", |
179 |
| - " </tr>\n", |
180 |
| - " <tr>\n", |
181 |
| - " <td style=\"text-align: left\"><b>Ray version:</b></td>\n", |
182 |
| - " <td style=\"text-align: left\"><b> 2.1.0</b></td>\n", |
183 |
| - " </tr>\n", |
184 |
| - " <tr>\n", |
185 |
| - " <td style=\"text-align: left\"><b>Dashboard:</b></td>\n", |
186 |
| - " <td style=\"text-align: left\"><b><a href=\"http://10.254.20.41:8265\" target=\"_blank\">http://10.254.20.41:8265</a></b></td>\n", |
187 |
| - "</tr>\n", |
188 |
| - "\n", |
189 |
| - " </table>\n", |
190 |
| - " </div>\n", |
191 |
| - "</div>\n" |
192 |
| - ], |
193 |
| - "text/plain": [ |
194 |
| - "ClientContext(dashboard_url='10.254.20.41:8265', python_version='3.8.13', ray_version='2.1.0', ray_commit='23f34d948dae8de9b168667ab27e6cf940b3ae85', protocol_version='2022-10-05', _num_clients=1, _context_to_restore=<ray.util.client._ClientContext object at 0x108ca2730>)" |
195 |
| - ] |
196 |
| - }, |
197 |
| - "execution_count": 6, |
198 |
| - "metadata": {}, |
199 |
| - "output_type": "execute_result" |
200 |
| - } |
201 |
| - ], |
| 122 | + "outputs": [], |
202 | 123 | "source": [
|
203 | 124 | "import ray\n",
|
204 | 125 | "\n",
|
|
208 | 129 | },
|
209 | 130 | {
|
210 | 131 | "cell_type": "code",
|
211 |
| - "execution_count": 7, |
| 132 | + "execution_count": null, |
212 | 133 | "id": "3436eb4a-217c-4109-a3c3-309fda7e2442",
|
213 | 134 | "metadata": {},
|
214 | 135 | "outputs": [],
|
|
232 | 153 | },
|
233 | 154 | {
|
234 | 155 | "cell_type": "code",
|
235 |
| - "execution_count": 8, |
| 156 | + "execution_count": null, |
236 | 157 | "id": "5cca1874-2be3-4631-ae48-9adfa45e3af3",
|
237 | 158 | "metadata": {
|
238 |
| - "scrolled": true, |
239 | 159 | "tags": []
|
240 | 160 | },
|
241 |
| - "outputs": [ |
242 |
| - { |
243 |
| - "name": "stderr", |
244 |
| - "output_type": "stream", |
245 |
| - "text": [ |
246 |
| - "2023-06-27 19:14:28,222\tDEBUG worker.py:640 -- Retaining 00ffffffffffffffffffffffffffffffffffffff0100000002000000\n", |
247 |
| - "2023-06-27 19:14:28,222\tDEBUG worker.py:564 -- Scheduling task heavy_calculation 0 b'\\x00\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\xff\\x01\\x00\\x00\\x00\\x02\\x00\\x00\\x00'\n" |
248 |
| - ] |
249 |
| - } |
250 |
| - ], |
| 161 | + "outputs": [], |
251 | 162 | "source": [
|
252 | 163 | "ref = heavy_calculation.remote(3000)"
|
253 | 164 | ]
|
254 | 165 | },
|
255 | 166 | {
|
256 | 167 | "cell_type": "code",
|
257 |
| - "execution_count": 9, |
| 168 | + "execution_count": null, |
258 | 169 | "id": "01172c29-e8bf-41ef-8db5-eccb07906111",
|
259 | 170 | "metadata": {},
|
260 |
| - "outputs": [ |
261 |
| - { |
262 |
| - "name": "stderr", |
263 |
| - "output_type": "stream", |
264 |
| - "text": [ |
265 |
| - "2023-06-27 19:14:29,202\tDEBUG worker.py:640 -- Retaining 16310a0f0a45af5cffffffffffffffffffffffff0100000001000000\n", |
266 |
| - "2023-06-27 19:14:31,224\tDEBUG worker.py:439 -- Internal retry for get [ClientObjectRef(16310a0f0a45af5cffffffffffffffffffffffff0100000001000000)]\n" |
267 |
| - ] |
268 |
| - }, |
269 |
| - { |
270 |
| - "data": { |
271 |
| - "text/plain": [ |
272 |
| - "1789.4644387076714" |
273 |
| - ] |
274 |
| - }, |
275 |
| - "execution_count": 9, |
276 |
| - "metadata": {}, |
277 |
| - "output_type": "execute_result" |
278 |
| - } |
279 |
| - ], |
| 171 | + "outputs": [], |
280 | 172 | "source": [
|
281 | 173 | "ray.get(ref)"
|
282 | 174 | ]
|
283 | 175 | },
|
284 | 176 | {
|
285 | 177 | "cell_type": "code",
|
286 |
| - "execution_count": 10, |
| 178 | + "execution_count": null, |
287 | 179 | "id": "9e79b547-a457-4232-b77d-19147067b972",
|
288 | 180 | "metadata": {},
|
289 |
| - "outputs": [ |
290 |
| - { |
291 |
| - "name": "stderr", |
292 |
| - "output_type": "stream", |
293 |
| - "text": [ |
294 |
| - "2023-06-27 19:14:33,161\tDEBUG dataclient.py:287 -- Got unawaited response connection_cleanup {\n", |
295 |
| - "}\n", |
296 |
| - "\n", |
297 |
| - "2023-06-27 19:14:34,460\tDEBUG dataclient.py:278 -- Shutting down data channel.\n" |
298 |
| - ] |
299 |
| - } |
300 |
| - ], |
| 181 | + "outputs": [], |
301 | 182 | "source": [
|
302 | 183 | "ray.cancel(ref)\n",
|
303 | 184 | "ray.shutdown()"
|
304 | 185 | ]
|
305 | 186 | },
|
306 | 187 | {
|
307 | 188 | "cell_type": "code",
|
308 |
| - "execution_count": 11, |
| 189 | + "execution_count": null, |
309 | 190 | "id": "2c198f1f-68bf-43ff-a148-02b5cb000ff2",
|
310 | 191 | "metadata": {},
|
311 | 192 | "outputs": [],
|
|
0 commit comments