ari/minerva
1
0
Fork 0
forked from bellwether/minerva
Code Pull requests Activity

enhancing CLI usage of starting a cluster

Browse source
This commit is contained in:
Ari Brown 2023-11-16 10:44:12 -05:00
parent fe06b6b808
commit 902302c9df
2 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
dask_test.py
View file

@ -52,10 +52,10 @@ try:
print(dp.count().compute())
with Timing("mean latitude"):
print(dp.map_partitions(lambda p: p.groupby(p.index).latitude.mean()).compute())
print(dp.groupby(dp.index).latitude.mean().compute())
with Timing("mean longitude"):
print(dp.map_partitions(lambda p: p.groupby(p.index).longitude.mean()).compute())
print(dp.groupby(dp.index).longitude.mean().compute())
finally:
########## FIN #######################