Skip to content

Commit db883ec

Browse files
raghukiran1224raghukiran1224
committedJun 21, 2021
Minor typos fixed in sample
·
0.1.2.dev0
1 parent adffee6 commit db883ec

File tree

1 file changed

+80
-66
lines changed

1 file changed

+80
-66
lines changed
 

Diff for: ‎notebooks/sample_pipeline.ipynb

+80-66
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@
159159
},
160160
{
161161
"cell_type": "code",
162-
"execution_count": 18,
162+
"execution_count": 8,
163163
"id": "greatest-cancellation",
164164
"metadata": {},
165165
"outputs": [],
@@ -183,7 +183,7 @@
183183
},
184184
{
185185
"cell_type": "code",
186-
"execution_count": 19,
186+
"execution_count": 22,
187187
"id": "coordinate-gossip",
188188
"metadata": {},
189189
"outputs": [],
@@ -194,15 +194,15 @@
194194
},
195195
{
196196
"cell_type": "code",
197-
"execution_count": 20,
197+
"execution_count": 23,
198198
"id": "bfe20bd8",
199199
"metadata": {},
200200
"outputs": [
201201
{
202202
"name": "stderr",
203203
"output_type": "stream",
204204
"text": [
205-
"2021-06-20 11:53:04,117\tINFO services.py:1269 -- View the Ray dashboard at \u001b[1m\u001b[32mhttp://127.0.0.1:8265\u001b[39m\u001b[22m\n"
205+
"2021-06-21 15:56:54,811\tINFO services.py:1269 -- View the Ray dashboard at \u001b[1m\u001b[32mhttp://127.0.0.1:8265\u001b[39m\u001b[22m\n"
206206
]
207207
},
208208
{
@@ -211,15 +211,15 @@
211211
"{'node_ip_address': '9.211.53.245',\n",
212212
" 'raylet_ip_address': '9.211.53.245',\n",
213213
" 'redis_address': '9.211.53.245:6379',\n",
214-
" 'object_store_address': '/tmp/ray/session_2021-06-20_11-53-02_767779_97928/sockets/plasma_store',\n",
215-
" 'raylet_socket_name': '/tmp/ray/session_2021-06-20_11-53-02_767779_97928/sockets/raylet',\n",
214+
" 'object_store_address': '/tmp/ray/session_2021-06-21_15-56-53_457589_24968/sockets/plasma_store',\n",
215+
" 'raylet_socket_name': '/tmp/ray/session_2021-06-21_15-56-53_457589_24968/sockets/raylet',\n",
216216
" 'webui_url': '127.0.0.1:8265',\n",
217-
" 'session_dir': '/tmp/ray/session_2021-06-20_11-53-02_767779_97928',\n",
218-
" 'metrics_export_port': 64339,\n",
219-
" 'node_id': '8c45750634c387b09b787fb7a0aa191df63f6d5274861bad27c00cb3'}"
217+
" 'session_dir': '/tmp/ray/session_2021-06-21_15-56-53_457589_24968',\n",
218+
" 'metrics_export_port': 61722,\n",
219+
" 'node_id': 'c3f600bfaa7bc8b7a6940e00f9ee026f7d3a208187bae30b39626e43'}"
220220
]
221221
},
222-
"execution_count": 20,
222+
"execution_count": 23,
223223
"metadata": {},
224224
"output_type": "execute_result"
225225
}
@@ -230,7 +230,7 @@
230230
},
231231
{
232232
"cell_type": "code",
233-
"execution_count": 21,
233+
"execution_count": 24,
234234
"id": "invisible-consensus",
235235
"metadata": {},
236236
"outputs": [],
@@ -240,7 +240,7 @@
240240
},
241241
{
242242
"cell_type": "code",
243-
"execution_count": 31,
243+
"execution_count": 25,
244244
"id": "surface-recruitment",
245245
"metadata": {},
246246
"outputs": [],
@@ -250,17 +250,23 @@
250250
},
251251
{
252252
"cell_type": "code",
253-
"execution_count": 32,
253+
"execution_count": 26,
254254
"id": "humanitarian-boards",
255255
"metadata": {},
256256
"outputs": [],
257257
"source": [
258258
"node_a = dm.EstimatorNode('preprocess', preprocessor)\n",
259-
"node_0 = dm.EstimatorNode('node_0', classifiers[0])\n",
260-
"node_1 = dm.EstimatorNode('node_1', classifiers[1])\n",
261-
"node_2 = dm.EstimatorNode('node_2', classifiers[2])\n",
262-
"node_3 = dm.EstimatorNode('node_3', classifiers[3])\n",
263-
"node_4 = dm.EstimatorNode('node_4', classifiers[4])\n",
259+
"k_nn = KNeighborsClassifier(3)\n",
260+
"svc = SVC(kernel=\"rbf\", C=0.025, probability=True)\n",
261+
"nu_svc = NuSVC(probability=True)\n",
262+
"rf = RandomForestClassifier()\n",
263+
"gbc = GradientBoostingClassifier()\n",
264+
"\n",
265+
"node_0 = dm.EstimatorNode('node_0', k_nn)\n",
266+
"node_1 = dm.EstimatorNode('node_1', svc)\n",
267+
"node_2 = dm.EstimatorNode('node_2', nu_svc)\n",
268+
"node_3 = dm.EstimatorNode('node_3', rf)\n",
269+
"node_4 = dm.EstimatorNode('node_4', gbc)\n",
264270
"\n",
265271
"pipeline.add_edge(node_a, node_0)\n",
266272
"pipeline.add_edge(node_a, node_1)\n",
@@ -271,7 +277,7 @@
271277
},
272278
{
273279
"cell_type": "code",
274-
"execution_count": 33,
280+
"execution_count": 27,
275281
"id": "ef9ff37b",
276282
"metadata": {},
277283
"outputs": [],
@@ -284,7 +290,7 @@
284290
},
285291
{
286292
"cell_type": "code",
287-
"execution_count": 34,
293+
"execution_count": 28,
288294
"id": "mineral-analyst",
289295
"metadata": {},
290296
"outputs": [],
@@ -294,7 +300,7 @@
294300
},
295301
{
296302
"cell_type": "code",
297-
"execution_count": 35,
303+
"execution_count": 29,
298304
"id": "literary-consolidation",
299305
"metadata": {},
300306
"outputs": [],
@@ -304,7 +310,7 @@
304310
},
305311
{
306312
"cell_type": "code",
307-
"execution_count": 36,
313+
"execution_count": 30,
308314
"id": "educated-basement",
309315
"metadata": {},
310316
"outputs": [],
@@ -315,92 +321,100 @@
315321
},
316322
{
317323
"cell_type": "code",
318-
"execution_count": 37,
319-
"id": "4df7fb29",
324+
"execution_count": 31,
325+
"id": "33fd7df4",
320326
"metadata": {},
321327
"outputs": [
322328
{
323329
"data": {
324330
"text/plain": [
325-
"[<codeflare.pipelines.Datamodel.XYRef at 0x7f97087200d0>]"
331+
"[<codeflare.pipelines.Datamodel.XYRef at 0x7fda28ce4fd0>]"
326332
]
327333
},
328-
"execution_count": 37,
334+
"execution_count": 31,
329335
"metadata": {},
330336
"output_type": "execute_result"
331337
}
332338
],
333339
"source": [
334-
"outputs[0]"
340+
"node_0_output"
335341
]
336342
},
337343
{
338344
"cell_type": "code",
339-
"execution_count": 39,
345+
"execution_count": 32,
340346
"id": "41955886",
341347
"metadata": {},
342348
"outputs": [],
343349
"source": [
344-
"X_out = ray.get(outputs[0][0].get_Xref())"
350+
"X_out = ray.get(node_0_output[0].get_Xref())"
345351
]
346352
},
347353
{
348354
"cell_type": "code",
349-
"execution_count": 40,
355+
"execution_count": 33,
350356
"id": "7e05451f",
351357
"metadata": {},
352358
"outputs": [
353359
{
354360
"data": {
355361
"text/plain": [
356-
"array(['Y', 'N', 'N', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y',\n",
357-
" 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y',\n",
362+
"array(['Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y',\n",
363+
" 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y',\n",
364+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
365+
" 'Y', 'Y', 'N', 'Y', 'N', 'N', 'N', 'Y', 'Y', 'N', 'N', 'N', 'N',\n",
366+
" 'Y', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y',\n",
367+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'N', 'N', 'N', 'Y', 'Y',\n",
368+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'N', 'Y', 'Y',\n",
358369
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N',\n",
359-
" 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N',\n",
360-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y',\n",
361-
" 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'N', 'Y', 'N', 'Y', 'Y', 'N', 'Y',\n",
362-
" 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'N', 'N', 'Y', 'N', 'N',\n",
363-
" 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'N',\n",
364-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'N', 'Y',\n",
365-
" 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y',\n",
366-
" 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'N', 'Y',\n",
367-
" 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y',\n",
368-
" 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
369-
" 'N', 'N', 'Y', 'Y', 'N', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
370-
" 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
371-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'N', 'Y', 'Y', 'N', 'Y',\n",
372-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y',\n",
373-
" 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'N', 'Y',\n",
370+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
371+
" 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'N', 'N', 'Y', 'Y', 'Y',\n",
372+
" 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
373+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y',\n",
374+
" 'Y', 'N', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
375+
" 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
376+
" 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
377+
" 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'N', 'Y',\n",
378+
" 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
379+
" 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'N', 'N', 'N', 'Y', 'N',\n",
380+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'N',\n",
381+
" 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'N', 'Y', 'N', 'Y', 'N',\n",
382+
" 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N',\n",
383+
" 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
384+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'N', 'Y', 'Y',\n",
385+
" 'Y', 'Y', 'N', 'N', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'Y',\n",
386+
" 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'Y',\n",
387+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y',\n",
388+
" 'Y', 'Y', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
389+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
374390
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
375-
" 'N', 'N', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
376-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'N',\n",
377-
" 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y',\n",
378-
" 'N', 'Y', 'Y', 'N', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
379-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y',\n",
380-
" 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N',\n",
381-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y',\n",
382-
" 'Y', 'N', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y',\n",
383-
" 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
384-
" 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'Y',\n",
385-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y',\n",
386-
" 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y',\n",
387-
" 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'N', 'N', 'Y', 'Y', 'N', 'Y', 'Y',\n",
388-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N',\n",
389-
" 'N', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
390-
" 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'N', 'Y', 'Y', 'Y',\n",
391+
" 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'N',\n",
391392
" 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
392-
" 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y',\n",
393-
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'N', 'Y'], dtype=object)"
393+
" 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N',\n",
394+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y',\n",
395+
" 'Y', 'N', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y', 'N', 'N', 'Y', 'Y',\n",
396+
" 'N', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'Y',\n",
397+
" 'Y', 'N', 'N', 'N', 'Y', 'N', 'Y', 'N', 'Y', 'Y', 'N', 'N', 'Y',\n",
398+
" 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'N', 'Y',\n",
399+
" 'Y', 'Y', 'Y', 'Y', 'N', 'Y', 'Y', 'Y', 'Y', 'N'], dtype=object)"
394400
]
395401
},
396-
"execution_count": 40,
402+
"execution_count": 33,
397403
"metadata": {},
398404
"output_type": "execute_result"
399405
}
400406
],
401407
"source": [
402408
"X_out"
403409
]
410+
},
411+
{
412+
"cell_type": "code",
413+
"execution_count": null,
414+
"id": "64a5bb35",
415+
"metadata": {},
416+
"outputs": [],
417+
"source": []
404418
}
405419
],
406420
"metadata": {

0 commit comments

Comments
 (0)
Please sign in to comment.