From c6280a3826729273d0d6222ae06f5355ff1cc08e Mon Sep 17 00:00:00 2001 From: Ari Brown Date: Thu, 16 Nov 2023 13:26:26 -0500 Subject: [PATCH] whoops, converting string to int --- dask_test.py | 6 +++--- run_cluster.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/dask_test.py b/dask_test.py index b92c8f0..2e2d938 100644 --- a/dask_test.py +++ b/dask_test.py @@ -49,13 +49,13 @@ try: IPython.embed() with Timing("count()"): - print(dp.count().compute()) + print(dp.count().visualize(filename='count.svg')) with Timing("mean latitude"): - print(dp.groupby(dp.index).latitude.mean().compute()) + print(dp.groupby(dp.index).latitude.mean().visualize(filename='latitude.svg')) with Timing("mean longitude"): - print(dp.groupby(dp.index).longitude.mean().compute()) + print(dp.groupby(dp.index).longitude.mean().visualize(filename='longitude.svg')) finally: ########## FIN ####################### diff --git a/run_cluster.py b/run_cluster.py index 815cf1f..164848f 100644 --- a/run_cluster.py +++ b/run_cluster.py @@ -33,7 +33,7 @@ pier = m.pier(subnet_id = "subnet-05eb26d8649a093e1", # project-subnet-public key_pair = ("Ari-Brown-HAY", "~/.ssh/Ari-Brown-HAY.pem"), iam = "Minerva") -cluster = pier.cluster(scheduler, worker, num_workers=sys.argv[1]) +cluster = pier.cluster(scheduler, worker, num_workers=int(sys.argv[1])) cluster.start() print(cluster.public_location)