Merge pull request #8085 from OpenMined/helm

Helm

.gitignore

@@ -71,5 +71,7 @@ js/node_modules/*
 #nohup
 nohup.out
 
+# notebook data
+notebooks/helm/scenario_data.jsonl
 # tox syft.build.helm generated file
 out.txt

notebooks/api/0.8/00-load-data.ipynb

@@ -662,6 +662,13 @@
     "if node.node_type.value == \"python\":\n",
     "    node.land()"
    ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": []
   }
  ],
  "metadata": {
@@ -680,7 +687,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.10.8"
+   "version": "3.9.16"
   },
   "toc": {
    "base_numbering": 1,

notebooks/api/0.8/01-submit-code.ipynb

@@ -504,7 +504,7 @@
    },
    "outputs": [],
    "source": [
-    "assert isinstance(result, sy.SyftNotReady)"
+    "assert isinstance(result, sy.SyftError)"
    ]
   },
   {
@@ -554,7 +554,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.11.3"
+   "version": "3.9.16"
   },
   "toc": {
    "base_numbering": 1,

notebooks/api/0.8/07-domain-register-control-flow.ipynb

@@ -56,7 +56,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "node = sy.orchestra.launch(name=\"test-domain-1\", port=\"auto\", dev_mode=True)"
+    "node = sy.orchestra.launch(name=\"test-domain-1\", port=\"auto\", dev_mode=True, reset=True)"
    ]
   },
   {
@@ -284,6 +284,14 @@
     "if node.node_type.value == \"python\":\n",
     "    node.land()"
    ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "58f96130",
+   "metadata": {},
+   "outputs": [],
+   "source": []
   }
  ],
  "metadata": {
@@ -302,7 +310,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.10.8"
+   "version": "3.9.16"
   },
   "toc": {
    "base_numbering": 1,

notebooks/api/0.8/09-blob-storage.ipynb

@@ -164,6 +164,9 @@
     "def retrieve_file(client, blob_storage_entry_id: sy.UID) -> Path:\n",
     "    blob_retrieval = client.api.services.blob_storage.read(blob_storage_entry_id)\n",
     "    file = blob_retrieval.read()\n",
+    "    content = file.read()\n",
+    "    with open(file.file_name, \"wb\") as f:\n",
+    "        f.write(content)\n",
     "    return Path(file.file_name)"
    ]
   },
@@ -193,15 +196,17 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "retrieved_file = retrieve_file(domain_client, uploaded_file_storage_id)"
+    "blob_retrieval = domain_client.api.services.blob_storage.read(uploaded_file_storage_id)"
    ]
   },
   {
    "cell_type": "code",
    "execution_count": null,
    "metadata": {},
    "outputs": [],
-   "source": []
+   "source": [
+    "retrieved_file = retrieve_file(domain_client, uploaded_file_storage_id)"
+   ]
   },
   {
    "cell_type": "markdown",
@@ -226,6 +231,15 @@
     "Retrieved file"
    ]
   },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "data_file"
+   ]
+  },
   {
    "cell_type": "code",
    "execution_count": null,
@@ -271,6 +285,16 @@
     "data_ptr = action_object.send(domain_client)"
    ]
   },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "with open(action_object.syft_action_data.file_name, \"wb\") as f:\n",
+    "    f.write(action_object.syft_action_data.read())"
+   ]
+  },
   {
    "cell_type": "code",
    "execution_count": null,
@@ -400,7 +424,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.11.1"
+   "version": "3.9.16"
   },
   "toc": {
    "base_numbering": 1,