dask / dask/distributed

No workers error when trying to scatter

Open
#2,941 7 comments 3 reactions 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.