diff --git a/examples/dask_cluster.py b/examples/dask_cluster.py index ab8f55f..160c102 100644 --- a/examples/dask_cluster.py +++ b/examples/dask_cluster.py @@ -69,17 +69,17 @@ try: with Timing("reading parquet"): df = dd.read_parquet("s3://haystac-archive-phase1.trial1/ta1.kitware/ta1/simulation/train/") - #with Timing("persisting"): - # dp = df.persist() + with Timing("persisting"): + dp = df.persist() - #with Timing("count()"): - # print(dp.count()) + with Timing("count()"): + print(dp.count()) - #with Timing("mean latitude"): - # print(dp.latitude.mean().compute()) + with Timing("mean latitude"): + print(dp.latitude.mean().compute()) - #with Timing("mean longitude"): - # print(dp.longitude.mean().compute()) + with Timing("mean longitude"): + print(dp.longitude.mean().compute()) finally: ########## FIN #######################