From 84a69594d328871128772cefd6a62b494792e77a Mon Sep 17 00:00:00 2001
From: Koen van der Veen <koenlennartvanderveen@gmail.com>
Date: Wed, 4 Oct 2023 11:08:15 +0200
Subject: [PATCH] -

---
 notebooks/helm/Untitled.ipynb                 |   6 +
 notebooks/helm/consumer node.ipynb            | 588 ++++++++++++++++++
 notebooks/helm/helm_syft.ipynb                | 190 +++---
 notebooks/helm/nested_syft_functions.ipynb    | 134 +---
 notebooks/helm/producer node.ipynb            | 521 ++++++++++++++++
 packages/syft/src/syft/node/node.py           |   4 +-
 .../syft/src/syft/service/job/job_stash.py    |   4 +-
 7 files changed, 1260 insertions(+), 187 deletions(-)
 create mode 100644 notebooks/helm/Untitled.ipynb
 create mode 100644 notebooks/helm/consumer node.ipynb
 create mode 100644 notebooks/helm/producer node.ipynb

diff --git a/notebooks/helm/Untitled.ipynb b/notebooks/helm/Untitled.ipynb
new file mode 100644
index 00000000000..363fcab7ed6
--- /dev/null
+++ b/notebooks/helm/Untitled.ipynb
@@ -0,0 +1,6 @@
+{
+ "cells": [],
+ "metadata": {},
+ "nbformat": 4,
+ "nbformat_minor": 5
+}
diff --git a/notebooks/helm/consumer node.ipynb b/notebooks/helm/consumer node.ipynb
new file mode 100644
index 00000000000..417e016c3c1
--- /dev/null
+++ b/notebooks/helm/consumer node.ipynb	
@@ -0,0 +1,588 @@
+{
+ "cells": [
+  {
+   "cell_type": "code",
+   "execution_count": 12,
+   "id": "a196017f",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "import syft as sy\n",
+    "from syft import ActionObject\n",
+    "from syft import syft_function, syft_function_single_use\n",
+    "from time import sleep\n",
+    "from syft.service.queue.zmq_queue import ZMQQueueConfig, ZMQClientConfig"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 13,
+   "id": "830cb5cf",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "spawning thread\n",
+      "spawning thread\n",
+      "spawning thread\n"
+     ]
+    }
+   ],
+   "source": [
+    "worker_node = sy.orchestra.launch(name=\"worker-node-helm1\", dev_mode=True, reset=True,\n",
+    "                                  n_consumers=3,\n",
+    "                                  queue_config=ZMQQueueConfig(client_config=ZMQClientConfig(\n",
+    "                                      create_producer=False,\n",
+    "                                      consumer_port=62249\n",
+    "                                  )\n",
+    "                                                             )\n",
+    "                                 )\n"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 14,
+   "id": "88fb4211",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "'tcp://localhost:62249'"
+      ]
+     },
+     "execution_count": 14,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "worker_node.python_node.queue_manager.consumers[\"api_call\"][0].address"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 11,
+   "id": "d1f13284",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Heartbeat failure, worker can't reach queue, reconnecting in 1sHeartbeat failure, worker can't reach queue, reconnecting in 1s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 1s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 2sHeartbeat failure, worker can't reach queue, reconnecting in 2s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 2s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 4s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 4s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 4s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 8sHeartbeat failure, worker can't reach queue, reconnecting in 8s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 8s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 16sHeartbeat failure, worker can't reach queue, reconnecting in 16s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 16s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32sHeartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n"
+     ]
+    },
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n"
+     ]
+    },
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n"
+     ]
+    },
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n",
+      "Heartbeat failure, worker can't reach queue, reconnecting in 32s\n"
+     ]
+    }
+   ],
+   "source": [
+    "sleep(3)"
+   ]
+  }
+ ],
+ "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.16"
+  },
+  "toc": {
+   "base_numbering": 1,
+   "nav_menu": {},
+   "number_sections": true,
+   "sideBar": true,
+   "skip_h1_title": false,
+   "title_cell": "Table of Contents",
+   "title_sidebar": "Contents",
+   "toc_cell": false,
+   "toc_position": {},
+   "toc_section_display": true,
+   "toc_window_display": true
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 5
+}
diff --git a/notebooks/helm/helm_syft.ipynb b/notebooks/helm/helm_syft.ipynb
index 8928d58a208..f815f47380b 100644
--- a/notebooks/helm/helm_syft.ipynb
+++ b/notebooks/helm/helm_syft.ipynb
@@ -32,14 +32,9 @@
      "name": "stdout",
      "output_type": "stream",
      "text": [
-      "CREATING A PRODUCER ON 57231\n",
-      "CREATING A CONSUMER ON tcp://localhost:57231\n",
       "spawning thread\n",
-      "CREATING A CONSUMER ON tcp://localhost:57231\n",
       "spawning thread\n",
-      "CREATING A CONSUMER ON tcp://localhost:57231\n",
       "spawning thread\n",
-      "CREATING A CONSUMER ON tcp://localhost:57231\n",
       "spawning thread\n",
       "Logged into <test-domain-helm2: High side Domain> as <info@openmined.org>\n"
      ]
@@ -131,11 +126,11 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 7,
+   "execution_count": 33,
    "metadata": {},
    "outputs": [],
    "source": [
-    "# for line in input_ptr.syft_action_data[0].iter_lines():\n",
+    "# for line in input_files_ptr.syft_action_data[0].iter_lines():\n",
     "#     print(line)"
    ]
   },
@@ -294,7 +289,7 @@
     "    N = [5, 9, 13]\n",
     "    jobs = []\n",
     "    for n in N[:1]:\n",
-    "        for scenario_file in scenario_files:        \n",
+    "        for scenario_file in scenario_files:\n",
     "            batch_job = domain.launch_job(\n",
     "                compute_document_data_overlap,\n",
     "                scenario_file=scenario_file,\n",
@@ -321,10 +316,10 @@
     {
      "data": {
       "text/html": [
-       "<div class=\"alert-success\" style=\"padding:5px;\"><strong>SyftSuccess</strong>: Request a362a0fc05e04a678f7323ad638a5375 changes applied</div><br />"
+       "<div class=\"alert-success\" style=\"padding:5px;\"><strong>SyftSuccess</strong>: Request 533767b8f9bd41c78b69ea478b032472 changes applied</div><br />"
       ],
       "text/plain": [
-       "SyftSuccess: Request a362a0fc05e04a678f7323ad638a5375 changes applied"
+       "SyftSuccess: Request 533767b8f9bd41c78b69ea478b032472 changes applied"
       ]
      },
      "execution_count": 11,
@@ -363,7 +358,7 @@
       "text/markdown": [
        "```python\n",
        "class Job:\n",
-       "    id: UID = 9ac59d21db1d424d8c75e8182a564a17\n",
+       "    id: UID = e255a2305b0b4f799ecc93a371af52d0\n",
        "    status: created\n",
        "    has_parent: False\n",
        "    result: None\n",
@@ -395,21 +390,14 @@
      "name": "stderr",
      "output_type": "stream",
      "text": [
-      "FUNCTION LOG (357baa07ea3646a394a90693dd191071): starting overlap computation\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): starting overlap computation\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): preparing scenarios and creating indexes\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): preparing scenarios and creating indexes\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): computing overlap\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): computing overlap\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): done\n",
-      "FUNCTION LOG (2157ddd1507a40fdba292bbf005d456c): done\n"
-     ]
-    },
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "E: Invalid message from worker: [b'']\n"
+      "FUNCTION LOG (5255e318dab149f1bdfc2f69ee743446): starting overlap computation\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): starting overlap computation\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): preparing scenarios and creating indexes\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): computing overlap\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): preparing scenarios and creating indexes\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): done\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): computing overlap\n",
+      "FUNCTION LOG (7145c863483a485e827998d7746d6afb): done\n"
      ]
     },
     {
@@ -637,7 +625,7 @@
        "        flex-grow: 0;\n",
        "    }\n",
        "\n",
-       "    .grid-table155a96a951b04e8b8fb79dc8218f6046 {\n",
+       "    .grid-table504cc0a0b9ec43579deddb1905dba8bf {\n",
        "        display:grid;\n",
        "        grid-template-columns: 1fr repeat(24, 1fr);\n",
        "        grid-template-rows: repeat(2, 1fr);\n",
@@ -809,25 +797,25 @@
        "            <div style=\"padding-top: 16px; display:flex;justify-content: space-between; align-items: center;\">\n",
        "                <div class='pt-25 gap-10' style=\"display:flex;\">\n",
        "                    <div class=\"search-field\">\n",
-       "                        <div id='search-menu155a96a951b04e8b8fb79dc8218f6046' class=\"syft-dropdown\" onclick=\"{\n",
-       "                            let doc = document.getElementById('search-dropdown-content155a96a951b04e8b8fb79dc8218f6046')\n",
+       "                        <div id='search-menu504cc0a0b9ec43579deddb1905dba8bf' class=\"syft-dropdown\" onclick=\"{\n",
+       "                            let doc = document.getElementById('search-dropdown-content504cc0a0b9ec43579deddb1905dba8bf')\n",
        "                            if (doc.style.display === 'block'){\n",
        "                                doc.style.display = 'none'\n",
        "                            } else {\n",
        "                                doc.style.display = 'block'\n",
        "                            }\n",
        "                            }\">\n",
-       "                            <div id='search-dropdown-content155a96a951b04e8b8fb79dc8218f6046' class='syft-dropdown-content'></div>\n",
+       "                            <div id='search-dropdown-content504cc0a0b9ec43579deddb1905dba8bf' class='syft-dropdown-content'></div>\n",
        "                            <script>\n",
-       "                                var element155a96a951b04e8b8fb79dc8218f6046 = [{\"id\": {\"value\": \"308e959993a2413d9e19d5f0229d097f\", \"type\": \"clipboard\"}, \"status\": \"completed\", \"has_parent\": true, \"result\": \"ActionDataEmpty UID: 85a7b63832ca4b23be08000b0fa06b25 <None>\", \"logs\": \"starting overlap computation\\n\", \"subjobs\": 0}, {\"id\": {\"value\": \"b9073384ef6e462ba56b70ed882d32f7\", \"type\": \"clipboard\"}, \"status\": \"completed\", \"has_parent\": true, \"result\": \"ActionDataEmpty UID: 998f7a7139954c3bb2c2a00a27feb1cb <None>\", \"logs\": \"...\\ndone\\ndone\\n\", \"subjobs\": 0}]\n",
-       "                                var page_size155a96a951b04e8b8fb79dc8218f6046 = 2\n",
-       "                                var pageIndex155a96a951b04e8b8fb79dc8218f6046 = 1\n",
-       "                                var paginatedElements155a96a951b04e8b8fb79dc8218f6046 = []\n",
-       "                                var activeFilter155a96a951b04e8b8fb79dc8218f6046;\n",
+       "                                var element504cc0a0b9ec43579deddb1905dba8bf = [{\"id\": {\"value\": \"c6e17be9c81f4c39babc8cd69d348bfa\", \"type\": \"clipboard\"}, \"status\": \"completed\", \"has_parent\": true, \"result\": \"ActionDataEmpty UID: c512b61eca7f4419b7c406dd283c3d66 <None>\", \"logs\": \"...\\ndone\\ncomputing overlap\\ndone\\n\", \"subjobs\": 0}, {\"id\": {\"value\": \"109e663238654bfe86ce0709e138d246\", \"type\": \"clipboard\"}, \"status\": \"completed\", \"has_parent\": true, \"result\": \"ActionDataEmpty UID: 1dde19d129c9419cb8a72774342a6ee6 <None>\", \"logs\": \"starting overlap computation\\n\", \"subjobs\": 0}]\n",
+       "                                var page_size504cc0a0b9ec43579deddb1905dba8bf = 2\n",
+       "                                var pageIndex504cc0a0b9ec43579deddb1905dba8bf = 1\n",
+       "                                var paginatedElements504cc0a0b9ec43579deddb1905dba8bf = []\n",
+       "                                var activeFilter504cc0a0b9ec43579deddb1905dba8bf;\n",
        "\n",
        "                                function buildDropDownMenu(elements){\n",
        "                                    let init_filter;\n",
-       "                                    let menu = document.getElementById('search-dropdown-content155a96a951b04e8b8fb79dc8218f6046')\n",
+       "                                    let menu = document.getElementById('search-dropdown-content504cc0a0b9ec43579deddb1905dba8bf')\n",
        "                                    if (elements.length > 0) {\n",
        "                                        let sample = elements[0]\n",
        "                                        for (const attr in sample) {\n",
@@ -837,10 +825,10 @@
        "                                            let content = document.createElement('div');\n",
        "                                            content.onclick = function(event) {\n",
        "                                                event.stopPropagation()\n",
-       "                                                document.getElementById('menu-active-filter155a96a951b04e8b8fb79dc8218f6046').innerText = attr;\n",
-       "                                                activeFilter155a96a951b04e8b8fb79dc8218f6046 = attr;\n",
+       "                                                document.getElementById('menu-active-filter504cc0a0b9ec43579deddb1905dba8bf').innerText = attr;\n",
+       "                                                activeFilter504cc0a0b9ec43579deddb1905dba8bf = attr;\n",
        "                                                document.getElementById(\n",
-       "                                                    'search-dropdown-content155a96a951b04e8b8fb79dc8218f6046'\n",
+       "                                                    'search-dropdown-content504cc0a0b9ec43579deddb1905dba8bf'\n",
        "                                                ).style.display= 'none';\n",
        "                                            }\n",
        "                                            content.classList.add(\"dd-options\");\n",
@@ -850,30 +838,30 @@
        "                                    } else {\n",
        "                                        let init_filter = '---'\n",
        "                                    }\n",
-       "                                    let dropdown_field = document.getElementById('search-menu155a96a951b04e8b8fb79dc8218f6046')\n",
+       "                                    let dropdown_field = document.getElementById('search-menu504cc0a0b9ec43579deddb1905dba8bf')\n",
        "                                    let span = document.createElement('span')\n",
-       "                                    span.setAttribute('id', 'menu-active-filter155a96a951b04e8b8fb79dc8218f6046')\n",
+       "                                    span.setAttribute('id', 'menu-active-filter504cc0a0b9ec43579deddb1905dba8bf')\n",
        "                                    span.innerText = init_filter\n",
-       "                                    activeFilter155a96a951b04e8b8fb79dc8218f6046 = init_filter;\n",
+       "                                    activeFilter504cc0a0b9ec43579deddb1905dba8bf = init_filter;\n",
        "                                    dropdown_field.appendChild(span)\n",
        "                                }\n",
        "\n",
-       "                                buildDropDownMenu(element155a96a951b04e8b8fb79dc8218f6046)\n",
+       "                                buildDropDownMenu(element504cc0a0b9ec43579deddb1905dba8bf)\n",
        "                            </script>\n",
        "                        </div>\n",
-       "                        <input id='searchKey155a96a951b04e8b8fb79dc8218f6046' class='search-input' placeholder='Enter search here ...'  />\n",
+       "                        <input id='searchKey504cc0a0b9ec43579deddb1905dba8bf' class='search-input' placeholder='Enter search here ...'  />\n",
        "                    </div>\n",
-       "                    <button class='search-button' type=\"button\" onclick=\"searchGrid155a96a951b04e8b8fb79dc8218f6046(element155a96a951b04e8b8fb79dc8218f6046)\">\n",
+       "                    <button class='search-button' type=\"button\" onclick=\"searchGrid504cc0a0b9ec43579deddb1905dba8bf(element504cc0a0b9ec43579deddb1905dba8bf)\">\n",
        "                        <svg width=\"11\" height=\"10\" viewBox=\"0 0 11 10\" fill=\"none\" xmlns=\"http://www.w3.org/2000/svg\"><path d=\"M10.5652 9.23467L8.21819 6.88811C8.89846 6.07141 9.23767 5.02389 9.16527 3.96345C9.09287 2.90302 8.61443 1.91132 7.82948 1.19466C7.04453 0.477995 6.01349 0.0915414 4.95087 0.115691C3.88824 0.139841 2.87583 0.572735 2.12425 1.32432C1.37266 2.0759 0.939768 3.08831 0.915618 4.15094C0.891468 5.21357 1.27792 6.2446 1.99459 7.02955C2.71125 7.8145 3.70295 8.29294 4.76338 8.36535C5.82381 8.43775 6.87134 8.09853 7.68804 7.41827L10.0346 9.7653C10.0694 9.80014 10.1108 9.82778 10.1563 9.84663C10.2018 9.86549 10.2506 9.87519 10.2999 9.87519C10.3492 9.87519 10.398 9.86549 10.4435 9.84663C10.489 9.82778 10.5304 9.80014 10.5652 9.7653C10.6001 9.73046 10.6277 9.68909 10.6466 9.64357C10.6654 9.59805 10.6751 9.54926 10.6751 9.49998C10.6751 9.45071 10.6654 9.40192 10.6466 9.3564C10.6277 9.31088 10.6001 9.26951 10.5652 9.23467ZM1.67491 4.24998C1.67491 3.58247 1.87285 2.92995 2.2437 2.37493C2.61455 1.81992 3.14165 1.38734 3.75835 1.13189C4.37506 0.876446 5.05366 0.809609 5.70834 0.939835C6.36303 1.07006 6.96439 1.3915 7.4364 1.8635C7.9084 2.3355 8.22984 2.93687 8.36006 3.59155C8.49029 4.24624 8.42345 4.92484 8.168 5.54154C7.91256 6.15824 7.47998 6.68535 6.92496 7.05619C6.36995 7.42704 5.71742 7.62498 5.04991 7.62498C4.15511 7.62399 3.29724 7.26809 2.66452 6.63537C2.0318 6.00265 1.6759 5.14479 1.67491 4.24998Z\" fill=\"currentColor\"/></svg>\n",
        "                        <span class='pl-8'>Search</span>\n",
        "                    </button>\n",
        "                </div>\n",
        "\n",
-       "                <div><h4 id='total155a96a951b04e8b8fb79dc8218f6046'>0</h4></div>\n",
+       "                <div><h4 id='total504cc0a0b9ec43579deddb1905dba8bf'>0</h4></div>\n",
        "            </div>\n",
-       "            <div id='table155a96a951b04e8b8fb79dc8218f6046' class='grid-table155a96a951b04e8b8fb79dc8218f6046' style='margin-top: 25px;'>\n",
+       "            <div id='table504cc0a0b9ec43579deddb1905dba8bf' class='grid-table504cc0a0b9ec43579deddb1905dba8bf' style='margin-top: 25px;'>\n",
        "                <script>\n",
-       "                    function paginate155a96a951b04e8b8fb79dc8218f6046(arr, size) {\n",
+       "                    function paginate504cc0a0b9ec43579deddb1905dba8bf(arr, size) {\n",
        "                        const res = [];\n",
        "                        for (let i = 0; i < arr.length; i += size) {\n",
        "                            const chunk = arr.slice(i, i + size);\n",
@@ -883,33 +871,33 @@
        "                        return res;\n",
        "                    }\n",
        "\n",
-       "                    function searchGrid155a96a951b04e8b8fb79dc8218f6046(elements){\n",
-       "                        let searchKey = document.getElementById('searchKey155a96a951b04e8b8fb79dc8218f6046').value;\n",
+       "                    function searchGrid504cc0a0b9ec43579deddb1905dba8bf(elements){\n",
+       "                        let searchKey = document.getElementById('searchKey504cc0a0b9ec43579deddb1905dba8bf').value;\n",
        "                        let result;\n",
        "                        if (searchKey === ''){\n",
        "                            result = elements;\n",
        "                        } else {\n",
        "                            result = elements.filter((element) => {\n",
-       "                                let property = element[activeFilter155a96a951b04e8b8fb79dc8218f6046]\n",
+       "                                let property = element[activeFilter504cc0a0b9ec43579deddb1905dba8bf]\n",
        "                                if (typeof property === 'object' && property !== null){\n",
        "                                    return property.value.toLowerCase().includes(searchKey.toLowerCase());\n",
        "                                } else if (typeof property === 'string' ) {\n",
-       "                                    return element[activeFilter155a96a951b04e8b8fb79dc8218f6046].toLowerCase().includes(searchKey.toLowerCase());\n",
+       "                                    return element[activeFilter504cc0a0b9ec43579deddb1905dba8bf].toLowerCase().includes(searchKey.toLowerCase());\n",
        "                                } else if (property !== null ) {\n",
-       "                                    return element[activeFilter155a96a951b04e8b8fb79dc8218f6046].toString() === searchKey;\n",
+       "                                    return element[activeFilter504cc0a0b9ec43579deddb1905dba8bf].toString() === searchKey;\n",
        "                                } else {\n",
-       "                                    return element[activeFilter155a96a951b04e8b8fb79dc8218f6046] === searchKey;\n",
+       "                                    return element[activeFilter504cc0a0b9ec43579deddb1905dba8bf] === searchKey;\n",
        "                                }\n",
        "                            } );\n",
        "                        }\n",
-       "                        resetById155a96a951b04e8b8fb79dc8218f6046('table155a96a951b04e8b8fb79dc8218f6046');\n",
-       "                        resetById155a96a951b04e8b8fb79dc8218f6046('pag155a96a951b04e8b8fb79dc8218f6046');\n",
-       "                        result = paginate155a96a951b04e8b8fb79dc8218f6046(result, page_size155a96a951b04e8b8fb79dc8218f6046)\n",
-       "                        buildGrid155a96a951b04e8b8fb79dc8218f6046(result,pageIndex155a96a951b04e8b8fb79dc8218f6046);\n",
-       "                        buildPaginationContainer155a96a951b04e8b8fb79dc8218f6046(result);\n",
+       "                        resetById504cc0a0b9ec43579deddb1905dba8bf('table504cc0a0b9ec43579deddb1905dba8bf');\n",
+       "                        resetById504cc0a0b9ec43579deddb1905dba8bf('pag504cc0a0b9ec43579deddb1905dba8bf');\n",
+       "                        result = paginate504cc0a0b9ec43579deddb1905dba8bf(result, page_size504cc0a0b9ec43579deddb1905dba8bf)\n",
+       "                        buildGrid504cc0a0b9ec43579deddb1905dba8bf(result,pageIndex504cc0a0b9ec43579deddb1905dba8bf);\n",
+       "                        buildPaginationContainer504cc0a0b9ec43579deddb1905dba8bf(result);\n",
        "                    }\n",
        "\n",
-       "                    function setTheme155a96a951b04e8b8fb79dc8218f6046(){\n",
+       "                    function setTheme504cc0a0b9ec43579deddb1905dba8bf(){\n",
        "                        const theme = document.body.getAttribute('data-jp-theme-light') === 'true' ? 'light' : 'dark';\n",
        "\n",
        "                        if (theme === 'dark') document.body.classList.add('dark-theme');\n",
@@ -917,21 +905,21 @@
        "\n",
        "                    }\n",
        "\n",
-       "                    function resetById155a96a951b04e8b8fb79dc8218f6046(id){\n",
+       "                    function resetById504cc0a0b9ec43579deddb1905dba8bf(id){\n",
        "                        let element = document.getElementById(id);\n",
        "                        while (element.firstChild) {\n",
        "                          element.removeChild(element.firstChild);\n",
        "                        }\n",
        "                    }\n",
        "\n",
-       "                    function buildGrid155a96a951b04e8b8fb79dc8218f6046(items, pageIndex){\n",
-       "                                let headers = Object.keys(element155a96a951b04e8b8fb79dc8218f6046[0]);\n",
+       "                    function buildGrid504cc0a0b9ec43579deddb1905dba8bf(items, pageIndex){\n",
+       "                                let headers = Object.keys(element504cc0a0b9ec43579deddb1905dba8bf[0]);\n",
        "\n",
-       "                                let grid = document.getElementById(\"table155a96a951b04e8b8fb79dc8218f6046\");\n",
+       "                                let grid = document.getElementById(\"table504cc0a0b9ec43579deddb1905dba8bf\");\n",
        "                                let div = document.createElement(\"div\");\n",
        "                                div.classList.add('grid-header', 'grid-index-cells');\n",
        "                                grid.appendChild(div);\n",
-       "                                setTheme155a96a951b04e8b8fb79dc8218f6046();\n",
+       "                                setTheme504cc0a0b9ec43579deddb1905dba8bf();\n",
        "                                headers.forEach((title) =>{\n",
        "                                    let div = document.createElement(\"div\");\n",
        "                                    div.classList.add('grid-header', 'grid-std-cells');\n",
@@ -942,13 +930,13 @@
        "\n",
        "                                let page = items[pageIndex -1]\n",
        "                                if (page !== 'undefine'){\n",
-       "                                    let table_index155a96a951b04e8b8fb79dc8218f6046 = ((pageIndex - 1) * page_size155a96a951b04e8b8fb79dc8218f6046)\n",
+       "                                    let table_index504cc0a0b9ec43579deddb1905dba8bf = ((pageIndex - 1) * page_size504cc0a0b9ec43579deddb1905dba8bf)\n",
        "                                    page.forEach((item) => {\n",
-       "                                        let grid = document.getElementById(\"table155a96a951b04e8b8fb79dc8218f6046\");\n",
+       "                                        let grid = document.getElementById(\"table504cc0a0b9ec43579deddb1905dba8bf\");\n",
        "                                        // Add new index value in index cells\n",
        "                                        let divIndex = document.createElement(\"div\");\n",
        "                                        divIndex.classList.add('grid-row', 'grid-index-cells');\n",
-       "                                        divIndex.innerText = table_index155a96a951b04e8b8fb79dc8218f6046;\n",
+       "                                        divIndex.innerText = table_index504cc0a0b9ec43579deddb1905dba8bf;\n",
        "                                        grid.appendChild(divIndex);\n",
        "\n",
        "                                        // Iterate over the actual obj\n",
@@ -1006,19 +994,19 @@
        "                                            }\n",
        "                                            grid.appendChild(div);\n",
        "                                        }\n",
-       "                                    table_index155a96a951b04e8b8fb79dc8218f6046 = table_index155a96a951b04e8b8fb79dc8218f6046 + 1;\n",
+       "                                    table_index504cc0a0b9ec43579deddb1905dba8bf = table_index504cc0a0b9ec43579deddb1905dba8bf + 1;\n",
        "                                    })\n",
        "                                }\n",
        "                    }\n",
-       "                    paginatedElements155a96a951b04e8b8fb79dc8218f6046 = paginate155a96a951b04e8b8fb79dc8218f6046(element155a96a951b04e8b8fb79dc8218f6046, page_size155a96a951b04e8b8fb79dc8218f6046)\n",
-       "                    buildGrid155a96a951b04e8b8fb79dc8218f6046(paginatedElements155a96a951b04e8b8fb79dc8218f6046, 1)\n",
-       "                    document.getElementById('total155a96a951b04e8b8fb79dc8218f6046').innerText = \"Total: \" + element155a96a951b04e8b8fb79dc8218f6046.length\n",
+       "                    paginatedElements504cc0a0b9ec43579deddb1905dba8bf = paginate504cc0a0b9ec43579deddb1905dba8bf(element504cc0a0b9ec43579deddb1905dba8bf, page_size504cc0a0b9ec43579deddb1905dba8bf)\n",
+       "                    buildGrid504cc0a0b9ec43579deddb1905dba8bf(paginatedElements504cc0a0b9ec43579deddb1905dba8bf, 1)\n",
+       "                    document.getElementById('total504cc0a0b9ec43579deddb1905dba8bf').innerText = \"Total: \" + element504cc0a0b9ec43579deddb1905dba8bf.length\n",
        "                </script>\n",
        "            </div>\n",
-       "            <div id='pag155a96a951b04e8b8fb79dc8218f6046' class='paginationContainer'>\n",
+       "            <div id='pag504cc0a0b9ec43579deddb1905dba8bf' class='paginationContainer'>\n",
        "                <script>\n",
-       "                    function buildPaginationContainer155a96a951b04e8b8fb79dc8218f6046(paginatedElements){\n",
-       "                            let pageContainer = document.getElementById(\"pag155a96a951b04e8b8fb79dc8218f6046\");\n",
+       "                    function buildPaginationContainer504cc0a0b9ec43579deddb1905dba8bf(paginatedElements){\n",
+       "                            let pageContainer = document.getElementById(\"pag504cc0a0b9ec43579deddb1905dba8bf\");\n",
        "                            for (let i = 0; i < paginatedElements.length; i++) {\n",
        "                                  let div = document.createElement(\"div\");\n",
        "                                  div.classList.add('page');\n",
@@ -1028,20 +1016,20 @@
        "                                      let indexes = document.getElementsByClassName('page');\n",
        "                                      for (let index of indexes) { index.style.color = 'var(--tertiary-color, \"gray\")' }\n",
        "                                      event.target.style.color = \"gray\";\n",
-       "                                      setPage155a96a951b04e8b8fb79dc8218f6046(i + 1);\n",
+       "                                      setPage504cc0a0b9ec43579deddb1905dba8bf(i + 1);\n",
        "                                  };\n",
        "                                  div.innerText = i + 1;\n",
        "                                  pageContainer.appendChild(div);\n",
        "                            }\n",
        "                    }\n",
        "\n",
-       "                    function setPage155a96a951b04e8b8fb79dc8218f6046(newPage){\n",
+       "                    function setPage504cc0a0b9ec43579deddb1905dba8bf(newPage){\n",
        "                        pageIndex = newPage\n",
-       "                        resetById155a96a951b04e8b8fb79dc8218f6046('table155a96a951b04e8b8fb79dc8218f6046')\n",
-       "                        buildGrid155a96a951b04e8b8fb79dc8218f6046(paginatedElements155a96a951b04e8b8fb79dc8218f6046, pageIndex)\n",
+       "                        resetById504cc0a0b9ec43579deddb1905dba8bf('table504cc0a0b9ec43579deddb1905dba8bf')\n",
+       "                        buildGrid504cc0a0b9ec43579deddb1905dba8bf(paginatedElements504cc0a0b9ec43579deddb1905dba8bf, pageIndex)\n",
        "                    }\n",
        "\n",
-       "                    buildPaginationContainer155a96a951b04e8b8fb79dc8218f6046(paginatedElements155a96a951b04e8b8fb79dc8218f6046)\n",
+       "                    buildPaginationContainer504cc0a0b9ec43579deddb1905dba8bf(paginatedElements504cc0a0b9ec43579deddb1905dba8bf)\n",
        "                </script>\n",
        "            </div>\n",
        "        </div>\n",
@@ -1071,6 +1059,12 @@
      "output_type": "stream",
      "text": [
       "starting overlap computation\n",
+      "preparing scenarios and creating indexes\n",
+      "computing overlap\n",
+      "preparing scenarios and creating indexes\n",
+      "done\n",
+      "computing overlap\n",
+      "done\n",
       "\n"
      ]
     }
@@ -1133,6 +1127,35 @@
     "results"
    ]
   },
+  {
+   "cell_type": "code",
+   "execution_count": 28,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "(defaultdict(set,\n",
+       "             {'philosophy_test_5': {'id328'}, 'philosophy_valid_5': {'id12'}}),\n",
+       " defaultdict(set, {}),\n",
+       " defaultdict(int,\n",
+       "             {'philosophy_train_5': 5,\n",
+       "              'philosophy_valid_5': 34,\n",
+       "              'philosophy_test_5': 311,\n",
+       "              'anatomy_train_5': 5,\n",
+       "              'anatomy_valid_5': 14,\n",
+       "              'anatomy_test_5': 135}))"
+      ]
+     },
+     "execution_count": 28,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "results[0]"
+   ]
+  },
   {
    "cell_type": "markdown",
    "metadata": {},
@@ -1279,7 +1302,12 @@
    "title_cell": "Table of Contents",
    "title_sidebar": "Contents",
    "toc_cell": false,
-   "toc_position": {},
+   "toc_position": {
+    "height": "calc(100% - 180px)",
+    "left": "10px",
+    "top": "150px",
+    "width": "398.22px"
+   },
    "toc_section_display": true,
    "toc_window_display": true
   }
diff --git a/notebooks/helm/nested_syft_functions.ipynb b/notebooks/helm/nested_syft_functions.ipynb
index 9fe83f0a1c6..2529e7386c7 100644
--- a/notebooks/helm/nested_syft_functions.ipynb
+++ b/notebooks/helm/nested_syft_functions.ipynb
@@ -2,76 +2,20 @@
  "cells": [
   {
    "cell_type": "code",
-   "execution_count": 1,
+   "execution_count": 3,
    "id": "a196017f",
    "metadata": {},
-   "outputs": [
-    {
-     "name": "stderr",
-     "output_type": "stream",
-     "text": [
-      "kj/filesystem-disk-unix.c++:1703: warning: PWD environment variable doesn't match current directory; pwd = /Users/koen/workspace/pysyft\n"
-     ]
-    }
-   ],
+   "outputs": [],
    "source": [
     "import syft as sy\n",
     "from syft import ActionObject\n",
     "from syft import syft_function, syft_function_single_use\n",
-    "from time import sleep"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 2,
-   "id": "95e55a0a",
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "# subprocess.check_output(\n",
-    "#         [lsof_path, \"-w\", \"-Fd\", \"-p\", str(os.getpid())]\n",
-    "#     ).decode().split(os.linesep)"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 3,
-   "id": "dcd8f67c",
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "import os"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 4,
-   "id": "151a3517",
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "from collections import Counter\n",
-    "def print_open_files():\n",
-    "    import psutil\n",
-    "\n",
-    "    files = psutil.Process(pid=os.getpid()).open_files()\n",
-    "    print('len(files):', len(files))\n",
-    "    print(Counter([f.path for f in files]))\n",
-    "#     for f in files:\n",
-    "#         print('FD:', f.fd, f.path)\n",
-    "    "
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 5,
-   "id": "ff6b7f51",
-   "metadata": {},
-   "outputs": [],
-   "source": [
+    "from time import sleep\n",
+    "import os\n",
     "import psutil\n",
     "\n",
-    "import inspect"
+    "import inspect\n",
+    "from syft.service.queue.zmq_queue import ZMQQueueConfig, ZMQClientConfig"
    ]
   },
   {
@@ -84,45 +28,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 6,
-   "id": "4cbee0b1",
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "# client = sy.login(port=8800, email=\"info@openmined.org\", password=\"changethis\")"
-   ]
-  },
-  {
-   "cell_type": "markdown",
-   "id": "6c9ce5a0",
-   "metadata": {},
-   "source": [
-    "Without server"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 7,
-   "id": "46b2c271",
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "# get_open_fds()"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 8,
-   "id": "0e8e3591",
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "# node.python_node"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": 9,
+   "execution_count": 5,
    "id": "9b31c627",
    "metadata": {},
    "outputs": [
@@ -130,7 +36,9 @@
      "name": "stdout",
      "output_type": "stream",
      "text": [
-      "CREATING A PRODUCER ON tcp://127.0.0.1:54341\n",
+      "spawning thread\n",
+      "spawning thread\n",
+      "spawning thread\n",
       "Logged into <test-domain-helm2: High side Domain> as <info@openmined.org>\n"
      ]
     },
@@ -148,7 +56,8 @@
     }
    ],
    "source": [
-    "node = sy.orchestra.launch(name=\"test-domain-helm2\", dev_mode=True, reset=True, n_consumers=0)\n",
+    "node = sy.orchestra.launch(name=\"test-domain-helm2\", dev_mode=True, reset=True, n_consumers=3,\n",
+    "                          queue_config=ZMQQueueConfig(client_config=ZMQClientConfig(create_producer=True)))\n",
     "client = node.login(email=\"info@openmined.org\", password=\"changethis\")"
    ]
   },
@@ -182,6 +91,25 @@
     "# client.register(name=\"a\", email=\"A@b.org\", password=\"AVC\")"
    ]
   },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "a8c342a6",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "from collections import Counter\n",
+    "def print_open_files():\n",
+    "    import psutil\n",
+    "\n",
+    "    files = psutil.Process(pid=os.getpid()).open_files()\n",
+    "    print('len(files):', len(files))\n",
+    "    print(Counter([f.path for f in files]))\n",
+    "#     for f in files:\n",
+    "#         print('FD:', f.fd, f.path)\n",
+    "    "
+   ]
+  },
   {
    "cell_type": "code",
    "execution_count": 13,
diff --git a/notebooks/helm/producer node.ipynb b/notebooks/helm/producer node.ipynb
new file mode 100644
index 00000000000..a92f06c6304
--- /dev/null
+++ b/notebooks/helm/producer node.ipynb	
@@ -0,0 +1,521 @@
+{
+ "cells": [
+  {
+   "cell_type": "code",
+   "execution_count": 1,
+   "id": "a196017f",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stderr",
+     "output_type": "stream",
+     "text": [
+      "kj/filesystem-disk-unix.c++:1703: warning: PWD environment variable doesn't match current directory; pwd = /Users/koen/workspace/pysyft\n"
+     ]
+    }
+   ],
+   "source": [
+    "import syft as sy\n",
+    "from syft import ActionObject\n",
+    "from syft import syft_function, syft_function_single_use\n",
+    "from time import sleep\n",
+    "from syft.service.queue.zmq_queue import ZMQQueueConfig, ZMQClientConfig"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "cb2d07de",
+   "metadata": {},
+   "source": [
+    "with server"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "id": "4cbee0b1",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "# client = sy.login(port=8800, email=\"info@openmined.org\", password=\"changethis\")"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "6c9ce5a0",
+   "metadata": {},
+   "source": [
+    "Without server"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 3,
+   "id": "9b31c627",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Logged into <test-domain-helm2: High side Domain> as <info@openmined.org>\n"
+     ]
+    },
+    {
+     "data": {
+      "text/html": [
+       "<div class=\"alert-warning\" style=\"padding:5px;\"><strong>SyftWarning</strong>: You are using a default password. Please change the password using `[your_client].me.set_password([new_password])`.</div><br />"
+      ],
+      "text/plain": [
+       "SyftWarning: You are using a default password. Please change the password using `[your_client].me.set_password([new_password])`."
+      ]
+     },
+     "metadata": {},
+     "output_type": "display_data"
+    }
+   ],
+   "source": [
+    "node = sy.orchestra.launch(name=\"test-domain-helm2\", dev_mode=True, reset=True,\n",
+    "                           n_consumers=0,\n",
+    "                           queue_config=ZMQQueueConfig(client_config=ZMQClientConfig(create_producer=True, \n",
+    "                                                                                    producer_port=62249)))\n",
+    "client = node.login(email=\"info@openmined.org\", password=\"changethis\")"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 4,
+   "id": "d3cf313b",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "62249"
+      ]
+     },
+     "execution_count": 4,
+     "metadata": {},
+     "output_type": "execute_result"
+    },
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Idle worker expired: b'DD14-4495'\n",
+      "Idle worker expired: b'B437-278B'\n",
+      "Idle worker expired: b'46F1-D8E4'\n"
+     ]
+    }
+   ],
+   "source": [
+    "node.python_node.queue_manager.producers[\"api_call\"].port"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "176addfb",
+   "metadata": {},
+   "source": [
+    "setup: compute train-test overlap between a very large train set and a smaller test set. Small test is still to big for memory, so we split it into 54 parts. We keep 1 of those parts in memory. We dont keep the train set in memory, but read and compare with 1/54 parts line by line. Each part takes ~30 hours, but we can run 54 processes in parallel."
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "a0cea81b",
+   "metadata": {},
+   "source": [
+    "# Setup syft functions"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "da2b114a",
+   "metadata": {},
+   "source": [
+    "## Dataset"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 17,
+   "id": "83307a2f",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "x = ActionObject.from_obj([1,2])\n",
+    "x_ptr = x.send(client)"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "31bbb3ff",
+   "metadata": {},
+   "source": [
+    "## Batch function"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 18,
+   "id": "5d2fd248",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/html": [
+       "<div class=\"alert-success\" style=\"padding:5px;\"><strong>SyftSuccess</strong>: Syft function 'process_batch' successfully created. To add a code request, please create a project using `project = syft.Project(...)`, then use command `project.create_code_request`.</div><br />"
+      ],
+      "text/plain": [
+       "SyftSuccess: Syft function 'process_batch' successfully created. To add a code request, please create a project using `project = syft.Project(...)`, then use command `project.create_code_request`."
+      ]
+     },
+     "metadata": {},
+     "output_type": "display_data"
+    }
+   ],
+   "source": [
+    "@syft_function()\n",
+    "def process_batch(batch):\n",
+    "    # takes 30 hours normally\n",
+    "    print(f\"starting batch {batch}\")\n",
+    "    from time import sleep\n",
+    "    sleep(1)\n",
+    "    print(\"done\")\n",
+    "    return batch+1"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 19,
+   "id": "9ba22655",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/html": [
+       "<div class=\"alert-success\" style=\"padding:5px;\"><strong>SyftSuccess</strong>: User Code Submitted</div><br />"
+      ],
+      "text/plain": [
+       "SyftSuccess: User Code Submitted"
+      ]
+     },
+     "execution_count": 19,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "client.code.submit(process_batch)"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "01319f1f",
+   "metadata": {},
+   "source": [
+    "## Main function"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 20,
+   "id": "ca1b95ee",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/html": [
+       "<div class=\"alert-success\" style=\"padding:5px;\"><strong>SyftSuccess</strong>: Syft function 'process_all' successfully created. To add a code request, please create a project using `project = syft.Project(...)`, then use command `project.create_code_request`.</div><br />"
+      ],
+      "text/plain": [
+       "SyftSuccess: Syft function 'process_all' successfully created. To add a code request, please create a project using `project = syft.Project(...)`, then use command `project.create_code_request`."
+      ]
+     },
+     "metadata": {},
+     "output_type": "display_data"
+    }
+   ],
+   "source": [
+    "@syft_function_single_use(x=x_ptr)\n",
+    "def process_all(domain, x):\n",
+    "    jobs = []\n",
+    "    print(\"Launching jobs\")\n",
+    "    for elem in x:\n",
+    "        # We inject a domain object in the scope\n",
+    "        batch_job = domain.launch_job(process_batch, batch=elem)\n",
+    "        jobs += [batch_job]\n",
+    "    print(\"starting aggregation\")\n",
+    "    print(\"Done\")\n",
+    "#     results = [x.wait().get() for x in jobs]\n",
+    "    return 1\n",
+    "#     return sum(results)"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "1e77c5db",
+   "metadata": {},
+   "source": [
+    "# Approve & run"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 21,
+   "id": "0ab572f9",
+   "metadata": {
+    "scrolled": false
+   },
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Request approved for domain test-domain-helm2\n"
+     ]
+    },
+    {
+     "data": {
+      "text/html": [
+       "<div class=\"alert-success\" style=\"padding:5px;\"><strong>SyftSuccess</strong>: Request 268550e4db7c4ce4b81e3fd43c4c4bb3 changes applied</div><br />"
+      ],
+      "text/plain": [
+       "SyftSuccess: Request 268550e4db7c4ce4b81e3fd43c4c4bb3 changes applied"
+      ]
+     },
+     "execution_count": 21,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "client.code.request_code_execution(process_all)\n",
+    "client.requests[-1].approve()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 22,
+   "id": "375ed965",
+   "metadata": {
+    "scrolled": true
+   },
+   "outputs": [],
+   "source": [
+    "job = client.code.process_all(x=x_ptr, blocking=False)\n",
+    "sleep(5)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "7f5ace83",
+   "metadata": {},
+   "outputs": [],
+   "source": []
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 23,
+   "id": "e7a94e1c",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "# print_open_files()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 24,
+   "id": "7b8b2a2e",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "res = job.wait().get()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 25,
+   "id": "3cba7a2a",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "1"
+      ]
+     },
+     "execution_count": 25,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "res"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 29,
+   "id": "22ac31a6",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "starting batch 2\n",
+      "done\n",
+      "done\n",
+      "\n"
+     ]
+    }
+   ],
+   "source": [
+    "job.subjobs[1].logs()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 30,
+   "id": "9cb2e2bf",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "starting batch 1\n",
+      "\n"
+     ]
+    }
+   ],
+   "source": [
+    "job.subjobs[0].logs()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 31,
+   "id": "7fb84ccd",
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "starting batch 2\n",
+      "done\n",
+      "done\n",
+      "\n"
+     ]
+    }
+   ],
+   "source": [
+    "job.subjobs[1].logs()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 34,
+   "id": "c3d7476b",
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "2"
+      ]
+     },
+     "execution_count": 34,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "job.subjobs[0].wait().get()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 32,
+   "id": "7c892dcc",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "# get_open_fds()"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "3d141e3b",
+   "metadata": {},
+   "source": [
+    "##### Next steps"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "4e856437",
+   "metadata": {},
+   "source": [
+    "\n",
+    "\n",
+    "- [x] seaweedfs\n",
+    "- - [wip] merge into normal code\n",
+    "- [x] Multiple consumers (queues)\n",
+    "- - [x] implement messagequeue\n",
+    "- - [x] integrate messagequeue with the rest of the code\n",
+    "- [x] test flow with async main function\n",
+    "- [x]  up datastructures for jobs and logs\n",
+    "- - [x] set up reprs\n",
+    "- [wip] integrate helm code\n",
+    "- [ ] test on large machine"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "5ab56b04",
+   "metadata": {},
+   "outputs": [],
+   "source": []
+  }
+ ],
+ "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.16"
+  },
+  "toc": {
+   "base_numbering": 1,
+   "nav_menu": {},
+   "number_sections": true,
+   "sideBar": true,
+   "skip_h1_title": false,
+   "title_cell": "Table of Contents",
+   "title_sidebar": "Contents",
+   "toc_cell": false,
+   "toc_position": {},
+   "toc_section_display": true,
+   "toc_window_display": true
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 5
+}
diff --git a/packages/syft/src/syft/node/node.py b/packages/syft/src/syft/node/node.py
index a5910bab326..bf6c385c47d 100644
--- a/packages/syft/src/syft/node/node.py
+++ b/packages/syft/src/syft/node/node.py
@@ -28,6 +28,8 @@
 from result import Result
 from typing_extensions import Self
 
+# first party
+
 # relative
 from .. import __version__
 from ..abstract_node import AbstractNode
@@ -383,7 +385,7 @@ def init_queue_manager(self, queue_config: Optional[QueueConfig], n_consumers):
                 producer.run()
                 address = producer.address
             else:
-                port = queue_config_.client_config.producer_port
+                port = queue_config_.client_config.consumer_port
                 if port is not None:
                     address = f"tcp://localhost:{port}"
                 else:
diff --git a/packages/syft/src/syft/service/job/job_stash.py b/packages/syft/src/syft/service/job/job_stash.py
index 3244d38ae11..d958d8bd953 100644
--- a/packages/syft/src/syft/service/job/job_stash.py
+++ b/packages/syft/src/syft/service/job/job_stash.py
@@ -101,8 +101,8 @@ def _coll_repr_(self) -> Dict[str, Any]:
         logs = self.logs(_print=False)
         log_lines = logs.split("\n")
         subjobs = self.subjobs
-        if len(log_lines) > 3:
-            logs = "...\n" + "\n".join(log_lines[-3:])
+        if len(log_lines) > 4:
+            logs = "...\n" + "\n".join(log_lines[-4:])
         else:
             logs = logs