fix fn image and add missing deploy

v3io · Apr 28, 2022 · 89f73f7 · 89f73f7
1 parent a2cf04a
commit 89f73f7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/data-ingestion-and-preparation/dask-cluster.ipynb b/data-ingestion-and-preparation/dask-cluster.ipynb
@@ -216,7 +216,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "fn = mlrun.code_to_function(\"test_dask\",  kind='job', handler=\"test_dask\").apply(mlrun.mount_v3io())"
+    "fn = mlrun.code_to_function(\"test_dask\",  kind='job', image='mlrun/mlrun', handler=\"test_dask\").apply(mlrun.mount_v3io())"
    ]
   },
   {
@@ -232,7 +232,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "dsf = mlrun.new_function(\"dask_init\", kind='dask', image='mlrun/ml-models').apply(mlrun.mount_v3io())"
+    "dsf = mlrun.new_function(\"dask_init\", kind='dask', image='mlrun/mlrun').apply(mlrun.mount_v3io())"
    ]
   },
   {
@@ -596,6 +596,7 @@
     }
    ],
    "source": [
+    "fn.deploy()\n",
     "fn.run(handler = test_dask,\n",
     "       inputs={\"dataset\": DATA_URL},\n",
     "       params={\"dask_client\": DASK_CLIENT})"