Commit 54aa9305 authored by Klaus Zimmermann's avatar Klaus Zimmermann
Browse files

Fix dask setup (closes #124)

parent df86bee1
...@@ -9,8 +9,7 @@ from dask.distributed import Client, LocalCluster ...@@ -9,8 +9,7 @@ from dask.distributed import Client, LocalCluster
class DistributedLocalClusterScheduler: class DistributedLocalClusterScheduler:
def __init__(self): def __init__(self):
self.cluster = LocalCluster( self.cluster = LocalCluster()
local_directory='/dev/shm/dask-worker-space')
self.client = Client(self.cluster) self.client = Client(self.cluster)
def __enter__(self): def __enter__(self):
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment