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)