{ "cells": [ { "cell_type": "markdown", "metadata": {}, "source": [ "# Parallelization with Dask" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "[Dask](https://docs.dask.org/en/latest/array.html) " ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "" ] }, { "cell_type": "code", "execution_count": 1, "metadata": {}, "outputs": [ { "data": { "text/html": [ "
\n", "
\n", "
\n", "

Client

\n", "

Client-f4f33458-7235-11f0-bc00-be1a4b830aa9

\n", " \n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", "
Connection method: Cluster objectCluster type: distributed.LocalCluster
\n", " Dashboard: http://127.0.0.1:8787/status\n", "
\n", "\n", " \n", "\n", " \n", "
\n", "

Cluster Info

\n", "
\n", "
\n", "
\n", "
\n", "

LocalCluster

\n", "

7b390fd6

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", "\n", " \n", "
\n", " Dashboard: http://127.0.0.1:8787/status\n", " \n", " Workers: 7\n", "
\n", " Total threads: 14\n", " \n", " Total memory: 36.00 GiB\n", "
Status: runningUsing processes: True
\n", "\n", "
\n", " \n", "

Scheduler Info

\n", " \n", "\n", "
\n", "
\n", "
\n", "
\n", "

Scheduler

\n", "

Scheduler-cdf8695e-51e9-4855-89ba-1bdb3c366c6d

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "
\n", " Comm: tcp://127.0.0.1:53361\n", " \n", " Workers: 0 \n", "
\n", " Dashboard: http://127.0.0.1:8787/status\n", " \n", " Total threads: 0\n", "
\n", " Started: Just now\n", " \n", " Total memory: 0 B\n", "
\n", "
\n", "
\n", "\n", "
\n", " \n", "

Workers

\n", " \n", "\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 0

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53378\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53382/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53364\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-0a7ek597\n", "
\n", "
\n", "
\n", "
\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 1

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53380\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53386/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53366\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-rhhm6tl3\n", "
\n", "
\n", "
\n", "
\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 2

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53379\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53383/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53368\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-89muf7s4\n", "
\n", "
\n", "
\n", "
\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 3

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53381\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53389/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53370\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-cvo9miq6\n", "
\n", "
\n", "
\n", "
\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 4

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53388\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53392/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53372\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-c9o_6x_l\n", "
\n", "
\n", "
\n", "
\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 5

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53391\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53395/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53374\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-m5g8sgks\n", "
\n", "
\n", "
\n", "
\n", " \n", "
\n", "
\n", "
\n", "
\n", " \n", "

Worker: 6

\n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", " \n", "\n", " \n", "\n", " \n", "\n", "
\n", " Comm: tcp://127.0.0.1:53394\n", " \n", " Total threads: 2\n", "
\n", " Dashboard: http://127.0.0.1:53397/status\n", " \n", " Memory: 5.14 GiB\n", "
\n", " Nanny: tcp://127.0.0.1:53376\n", "
\n", " Local directory: /var/folders/8f/1b9jykm565z0yjl1_pkz3tt40000gn/T/dask-scratch-space/worker-x8a3xu7e\n", "
\n", "
\n", "
\n", "
\n", " \n", "\n", "
\n", "
\n", "\n", "
\n", "
\n", "
\n", "
\n", " \n", "\n", "
\n", "
" ], "text/plain": [ "" ] }, "execution_count": 1, "metadata": {}, "output_type": "execute_result" } ], "source": [ "from dask.distributed import LocalCluster, Client\n", "cluster = LocalCluster()\n", "client = Client(cluster)\n", "client" ] }, { "cell_type": "code", "execution_count": 2, "metadata": {}, "outputs": [], "source": [ "client.close()" ] }, { "cell_type": "markdown", "metadata": {}, "source": [] } ], "metadata": { "kernelspec": { "display_name": "scicompute", "language": "python", "name": "python3" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.12.2" } }, "nbformat": 4, "nbformat_minor": 2 }