Skip to content

Commit 2a0616a

Browse files
author
Mike McCarty
authored
Update scheduler demo to illustrate performance differences (#178)
1 parent 4ab5674 commit 2a0616a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

05_distributed.ipynb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,8 @@
7272
" 'CRSElapsedTime': float,\n",
7373
" 'Cancelled': bool})\n",
7474
"\n",
75-
"# Maximum non-cancelled delay\n",
76-
"largest_delay = df[~df.Cancelled].DepDelay.max()\n",
75+
"# Maximum average non-cancelled delay grouped by Airport\n",
76+
"largest_delay = df[~df.Cancelled].groupby('Origin').DepDelay.mean().max()\n",
7777
"largest_delay"
7878
]
7979
},
@@ -88,9 +88,9 @@
8888
"import time\n",
8989
"for sch in ['threading', 'processes', 'sync']:\n",
9090
" t0 = time.time()\n",
91-
" _ = largest_delay.compute(scheduler=sch)\n",
91+
" r = largest_delay.compute(scheduler=sch)\n",
9292
" t1 = time.time()\n",
93-
" print(f\"{sch:>10}, {t1 - t0:0.4f}\")"
93+
" print(f\"{sch:>10}, {t1 - t0:0.4f} s; result, {r:0.2f} hours\")"
9494
]
9595
},
9696
{

0 commit comments

Comments
 (0)