No workers error when trying to scatter
Open
- Dominant language
- Python
- Stars
- 1.7k
- Forks
- 778
- Avg merge
- 2h 50m
- Merged PRs (30d)
- 3
Description
I am trying to scatter data to workers but getting a `TimeoutError: No workers found`. I can do `sacct` and see my workers running, despite dask throwing this error. Here is a minimal working example which produces the error on my machine:
```
from dask_jobqueue import SLURMCluster
from dask.distributed import Client
cluster = SLURMCluster(cores=1,memory="19 GB",interface='ib0')
cluster.scale(2)
client = Client(cluster)
[future] = client.scatter([1.0], broadcast=True)
```
Contributor guide
Assessment
This issue has not been assessed yet.