|
26 | 26 | "The link to the dashboard will become visible when you create the client below. We recommend having it open on one side of your screen while using your notebook on the other side. This can take some effort to arrange your windows, but seeing them both at the same time is very useful when learning." |
27 | 27 | ] |
28 | 28 | }, |
29 | | - { |
30 | | - "cell_type": "code", |
31 | | - "execution_count": 4, |
32 | | - "metadata": {}, |
33 | | - "outputs": [ |
34 | | - { |
35 | | - "ename": "ModuleNotFoundError", |
36 | | - "evalue": "No module named 'dask'", |
37 | | - "output_type": "error", |
38 | | - "traceback": [ |
39 | | - "\u001b[31m---------------------------------------------------------------------------\u001b[39m", |
40 | | - "\u001b[31mModuleNotFoundError\u001b[39m Traceback (most recent call last)", |
41 | | - "\u001b[36mCell\u001b[39m\u001b[36m \u001b[39m\u001b[32mIn[4]\u001b[39m\u001b[32m, line 1\u001b[39m\n\u001b[32m----> \u001b[39m\u001b[32m1\u001b[39m \u001b[38;5;28;01mfrom\u001b[39;00m\u001b[38;5;250m \u001b[39m\u001b[34;01mdask\u001b[39;00m\u001b[34;01m.\u001b[39;00m\u001b[34;01mdistributed\u001b[39;00m\u001b[38;5;250m \u001b[39m\u001b[38;5;28;01mimport\u001b[39;00m Client, progress\n\u001b[32m 2\u001b[39m client = Client(n_workers=\u001b[32m4\u001b[39m, threads_per_worker=\u001b[32m1\u001b[39m)\n\u001b[32m 3\u001b[39m client\n", |
42 | | - "\u001b[31mModuleNotFoundError\u001b[39m: No module named 'dask'" |
43 | | - ] |
44 | | - } |
45 | | - ], |
46 | | - "source": [ |
47 | | - "from dask.distributed import Client, progress\n", |
48 | | - "client = Client(n_workers=4, threads_per_worker=1)\n", |
49 | | - "client" |
50 | | - ] |
51 | | - }, |
52 | 29 | { |
53 | 30 | "cell_type": "markdown", |
54 | 31 | "metadata": {}, |
|
251 | 228 | "b.map(flatten).take(1)" |
252 | 229 | ] |
253 | 230 | }, |
254 | | - { |
255 | | - "cell_type": "code", |
256 | | - "execution_count": 5, |
257 | | - "metadata": {}, |
258 | | - "outputs": [ |
259 | | - { |
260 | | - "ename": "NameError", |
261 | | - "evalue": "name 'b' is not defined", |
262 | | - "output_type": "error", |
263 | | - "traceback": [ |
264 | | - "\u001b[31m---------------------------------------------------------------------------\u001b[39m", |
265 | | - "\u001b[31mNameError\u001b[39m Traceback (most recent call last)", |
266 | | - "\u001b[36mCell\u001b[39m\u001b[36m \u001b[39m\u001b[32mIn[5]\u001b[39m\u001b[32m, line 1\u001b[39m\n\u001b[32m----> \u001b[39m\u001b[32m1\u001b[39m df = \u001b[43mb\u001b[49m.map(flatten).to_dataframe()\n\u001b[32m 2\u001b[39m df.head()\n", |
267 | | - "\u001b[31mNameError\u001b[39m: name 'b' is not defined" |
268 | | - ] |
269 | | - } |
270 | | - ], |
271 | | - "source": [ |
272 | | - "df = b.map(flatten).to_dataframe()\n", |
273 | | - "df.head()" |
274 | | - ] |
275 | | - }, |
276 | 231 | { |
277 | 232 | "cell_type": "markdown", |
278 | 233 | "metadata": {}, |
|
0 commit comments