diff --git a/examples/03_mpi/mpi_test.ipynb b/examples/03_mpi/mpi_test.ipynb
deleted file mode 100644
index 0694adf..0000000
--- a/examples/03_mpi/mpi_test.ipynb
+++ /dev/null
@@ -1,158 +0,0 @@
-{
- "cells": [
-  {
-   "cell_type": "code",
-   "execution_count": 1,
-   "id": "1f70b392",
-   "metadata": {},
-   "outputs": [
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "Starting 48 engines with <class 'ipyparallel.cluster.launcher.LocalEngineSetLauncher'>\n"
-     ]
-    },
-    {
-     "data": {
-      "application/vnd.jupyter.widget-view+json": {
-       "model_id": "86e3ac8b5a16405783756d02f8bb7fde",
-       "version_major": 2,
-       "version_minor": 0
-      },
-      "text/plain": [
-       "sleep:   0%|          | 0/25 [00:00<?, ?tasks/s]"
-      ]
-     },
-     "metadata": {},
-     "output_type": "display_data"
-    },
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "Stopping engine(s): 1637855022\n",
-      "engine set stopped 1637855022: {'engines': {'0': {'exit_code': 0, 'pid': 218702, 'identifier': '0'}, '1': {'exit_code': 0, 'pid': 218705, 'identifier': '1'}, '2': {'exit_code': 0, 'pid': 218707, 'identifier': '2'}, '3': {'exit_code': 0, 'pid': 218709, 'identifier': '3'}, '4': {'exit_code': 0, 'pid': 218711, 'identifier': '4'}, '5': {'exit_code': 0, 'pid': 218713, 'identifier': '5'}, '6': {'exit_code': 0, 'pid': 218719, 'identifier': '6'}, '7': {'exit_code': 0, 'pid': 218723, 'identifier': '7'}, '8': {'exit_code': 0, 'pid': 218733, 'identifier': '8'}, '9': {'exit_code': 0, 'pid': 218739, 'identifier': '9'}, '10': {'exit_code': 0, 'pid': 218745, 'identifier': '10'}, '11': {'exit_code': 0, 'pid': 218751, 'identifier': '11'}, '12': {'exit_code': 0, 'pid': 218759, 'identifier': '12'}, '13': {'exit_code': 0, 'pid': 218765, 'identifier': '13'}, '14': {'exit_code': 0, 'pid': 218768, 'identifier': '14'}, '15': {'exit_code': 0, 'pid': 218780, 'identifier': '15'}, '16': {'exit_code': 0, 'pid': 218796, 'identifier': '16'}, '17': {'exit_code': 0, 'pid': 218811, 'identifier': '17'}, '18': {'exit_code': 0, 'pid': 218818, 'identifier': '18'}, '19': {'exit_code': 0, 'pid': 218834, 'identifier': '19'}, '20': {'exit_code': 0, 'pid': 218847, 'identifier': '20'}, '21': {'exit_code': 0, 'pid': 218863, 'identifier': '21'}, '22': {'exit_code': 0, 'pid': 218886, 'identifier': '22'}, '23': {'exit_code': 0, 'pid': 218906, 'identifier': '23'}, '24': {'exit_code': 0, 'pid': 218922, 'identifier': '24'}, '25': {'exit_code': 0, 'pid': 218938, 'identifier': '25'}, '26': {'exit_code': 0, 'pid': 218954, 'identifier': '26'}, '27': {'exit_code': 0, 'pid': 218971, 'identifier': '27'}, '28': {'exit_code': 0, 'pid': 218985, 'identifier': '28'}, '29': {'exit_code': 0, 'pid': 219004, 'identifier': '29'}, '30': {'exit_code': 0, 'pid': 219020, 'identifier': '30'}, '31': {'exit_code': 0, 'pid': 219036, 'identifier': '31'}, '32': {'exit_code': 0, 'pid': 219052, 'identifier': '32'}, '33': {'exit_code': 0, 'pid': 219063, 'identifier': '33'}, '34': {'exit_code': 0, 'pid': 219083, 'identifier': '34'}, '35': {'exit_code': 0, 'pid': 219104, 'identifier': '35'}, '36': {'exit_code': 0, 'pid': 219124, 'identifier': '36'}, '37': {'exit_code': 0, 'pid': 219141, 'identifier': '37'}, '38': {'exit_code': 0, 'pid': 219161, 'identifier': '38'}, '39': {'exit_code': 0, 'pid': 219184, 'identifier': '39'}, '40': {'exit_code': 0, 'pid': 219196, 'identifier': '40'}, '41': {'exit_code': 0, 'pid': 219213, 'identifier': '41'}, '42': {'exit_code': 0, 'pid': 219229, 'identifier': '42'}, '43': {'exit_code': 0, 'pid': 219248, 'identifier': '43'}, '44': {'exit_code': 0, 'pid': 219267, 'identifier': '44'}, '45': {'exit_code': 0, 'pid': 219283, 'identifier': '45'}, '46': {'exit_code': 0, 'pid': 219292, 'identifier': '46'}, '47': {'exit_code': 0, 'pid': 219314, 'identifier': '47'}}, 'exit_code': 0}\n",
-      "Stopping controller\n",
-      "Controller stopped: {'exit_code': 0, 'pid': 218649, 'identifier': 'ipcontroller-1637855021-gfdv-218555'}\n"
-     ]
-    }
-   ],
-   "source": [
-    "from __future__ import annotations\n",
-    "\n",
-    "import time\n",
-    "\n",
-    "import ipyparallel as ipp\n",
-    "\n",
-    "task_durations = [1] * 25\n",
-    "# request a cluster\n",
-    "with ipp.Cluster() as rc:\n",
-    "    # get a view on the cluster\n",
-    "    view = rc.load_balanced_view()\n",
-    "    # submit the tasks\n",
-    "    asyncresult = view.map_async(time.sleep, task_durations)\n",
-    "    # wait interactively for results\n",
-    "    asyncresult.wait_interactive()\n",
-    "    # retrieve actual results\n",
-    "    result = asyncresult.get()\n",
-    "# at this point, the cluster processes have been shutdown"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 2,
-   "id": "8da6955e",
-   "metadata": {},
-   "outputs": [
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "Starting 4 engines with <class 'ipyparallel.cluster.launcher.MPIEngineSetLauncher'>\n"
-     ]
-    },
-    {
-     "data": {
-      "application/vnd.jupyter.widget-view+json": {
-       "model_id": "7b55f85ec1184a43aac3c2ef3800acb8",
-       "version_major": 2,
-       "version_minor": 0
-      },
-      "text/plain": [
-       "  0%|          | 0/4 [00:00<?, ?engine/s]"
-      ]
-     },
-     "metadata": {},
-     "output_type": "display_data"
-    },
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "engine set stopped 1637855042: {'exit_code': 255, 'pid': 219803, 'identifier': 'ipengine-1637855041-1tp7-1637855042-218555'}\n"
-     ]
-    },
-    {
-     "ename": "EngineError",
-     "evalue": "Engine set stopped: {'exit_code': 255, 'pid': 219803, 'identifier': 'ipengine-1637855041-1tp7-1637855042-218555'}",
-     "output_type": "error",
-     "traceback": [
-      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
-      "\u001b[0;31mEngineError\u001b[0m                               Traceback (most recent call last)",
-      "\u001b[0;32m/tmp/ab542498/login18-2_104474/ipykernel_218555/1896274520.py\u001b[0m in \u001b[0;36m<module>\u001b[0;34m\u001b[0m\n\u001b[1;32m      7\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      8\u001b[0m \u001b[0;31m# request an MPI cluster with 4 engines\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m----> 9\u001b[0;31m \u001b[0;32mwith\u001b[0m \u001b[0mipp\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mCluster\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mengines\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;34m'mpi'\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mn\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;36m4\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0mrc\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m     10\u001b[0m     \u001b[0;31m# get a broadcast_view on the cluster which is best\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     11\u001b[0m     \u001b[0;31m# suited for MPI style computation\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/cluster/home/ab542498/python/base-3.9/lib/python3.9/site-packages/ipyparallel/cluster/cluster.py\u001b[0m in \u001b[0;36m__enter__\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    873\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    874\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0m__enter__\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 875\u001b[0;31m         \u001b[0mclient\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_context_client\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mstart_and_connect_sync\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    876\u001b[0m         \u001b[0;32mreturn\u001b[0m \u001b[0mclient\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    877\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/cluster/home/ab542498/python/base-3.9/lib/python3.9/site-packages/ipyparallel/_async.py\u001b[0m in \u001b[0;36m_synchronize\u001b[0;34m(self, async_f, *args, **kwargs)\u001b[0m\n\u001b[1;32m     68\u001b[0m             \u001b[0mloop\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mNone\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     69\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mloop\u001b[0m \u001b[0;32mand\u001b[0m \u001b[0mloop\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mis_running\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 70\u001b[0;31m             \u001b[0;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_in_thread\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0masync_f\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m*\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m     71\u001b[0m         \u001b[0;32melse\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     72\u001b[0m             \u001b[0;32mreturn\u001b[0m \u001b[0m_asyncio_run\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0masync_f\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m*\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/cluster/home/ab542498/python/base-3.9/lib/python3.9/site-packages/ipyparallel/_async.py\u001b[0m in \u001b[0;36m_in_thread\u001b[0;34m(self, async_f, *args, **kwargs)\u001b[0m\n\u001b[1;32m     53\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     54\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_thread_loop\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0madd_callback\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mthread_callback\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 55\u001b[0;31m         \u001b[0;32mreturn\u001b[0m \u001b[0mfuture\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mresult\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m     56\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     57\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0m_synchronize\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0masync_f\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m*\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/SW/UTIL.common/Python/3.9.1/x86_64/lib/python3.9/concurrent/futures/_base.py\u001b[0m in \u001b[0;36mresult\u001b[0;34m(self, timeout)\u001b[0m\n\u001b[1;32m    438\u001b[0m                 \u001b[0;32mraise\u001b[0m \u001b[0mCancelledError\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    439\u001b[0m             \u001b[0;32melif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_state\u001b[0m \u001b[0;34m==\u001b[0m \u001b[0mFINISHED\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 440\u001b[0;31m                 \u001b[0;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m__get_result\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    441\u001b[0m             \u001b[0;32melse\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    442\u001b[0m                 \u001b[0;32mraise\u001b[0m \u001b[0mTimeoutError\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/SW/UTIL.common/Python/3.9.1/x86_64/lib/python3.9/concurrent/futures/_base.py\u001b[0m in \u001b[0;36m__get_result\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    387\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0m__get_result\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    388\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_exception\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 389\u001b[0;31m             \u001b[0;32mraise\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_exception\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    390\u001b[0m         \u001b[0;32melse\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    391\u001b[0m             \u001b[0;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_result\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/cluster/home/ab542498/python/base-3.9/lib/python3.9/site-packages/ipyparallel/_async.py\u001b[0m in \u001b[0;36mthread_callback\u001b[0;34m()\u001b[0m\n\u001b[1;32m     48\u001b[0m         \u001b[0;32masync\u001b[0m \u001b[0;32mdef\u001b[0m \u001b[0mthread_callback\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     49\u001b[0m             \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 50\u001b[0;31m                 \u001b[0mfuture\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mset_result\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;32mawait\u001b[0m \u001b[0masync_f\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m*\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m     51\u001b[0m             \u001b[0;32mexcept\u001b[0m \u001b[0mException\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     52\u001b[0m                 \u001b[0mfuture\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mset_exception\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0me\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
-      "\u001b[0;32m/rwthfs/rz/cluster/home/ab542498/python/base-3.9/lib/python3.9/site-packages/ipyparallel/cluster/cluster.py\u001b[0m in \u001b[0;36mstart_and_connect\u001b[0;34m(self, n)\u001b[0m\n\u001b[1;32m    728\u001b[0m         \u001b[0mclient\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mawait\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mconnect_client\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    729\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mn\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 730\u001b[0;31m             await asyncio.wrap_future(\n\u001b[0m\u001b[1;32m    731\u001b[0m                 \u001b[0mclient\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mwait_for_engines\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mn\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mblock\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;32mFalse\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mtimeout\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mengine_timeout\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    732\u001b[0m             )\n",
-      "\u001b[0;31mEngineError\u001b[0m: Engine set stopped: {'exit_code': 255, 'pid': 219803, 'identifier': 'ipengine-1637855041-1tp7-1637855042-218555'}"
-     ]
-    }
-   ],
-   "source": [
-    "import ipyparallel as ipp\n",
-    "\n",
-    "\n",
-    "def mpi_example() -> str:  # noqa: D103\n",
-    "    from mpi4py import MPI\n",
-    "    comm = MPI.COMM_WORLD\n",
-    "    return f\"Hello World from rank {comm.Get_rank()}. total ranks={comm.Get_size()}\"\n",
-    "\n",
-    "# request an MPI cluster with 4 engines\n",
-    "with ipp.Cluster(engines=\"mpi\", n=4) as rc:\n",
-    "    # get a broadcast_view on the cluster which is best\n",
-    "    # suited for MPI style computation\n",
-    "    view = rc.broadcast_view()\n",
-    "    # run the mpi_example function on all engines in parallel\n",
-    "    r = view.apply_sync(mpi_example)\n",
-    "    # Retrieve and print the result from the engines\n",
-    "    print(\"\\n\".join(r))\n",
-    "# at this point, the cluster processes have been shutdown"
-   ]
-  }
- ],
- "metadata": {
-  "kernelspec": {
-   "display_name": "Python 3 (ipykernel)",
-   "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.9.6"
-  }
- },
- "nbformat": 4,
- "nbformat_minor": 5
-}