From 937ca168ada139d8532cdfc21183247e9e46bca7 Mon Sep 17 00:00:00 2001 From: Ari Brown Date: Thu, 12 Oct 2023 14:59:54 -0400 Subject: [PATCH] updated dask cluster example --- examples/dask_cluster.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) 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 #######################