Can LocalCluster be in a context?

[CMCDragonkai]

It doesn't seem like it's possible to use with LocalCluster(), instead an explicit close is required.

[CMCDragonkai]

Even calling cluster.close() can still sometimes result in:

distributed.comm.tcp - WARNING - Closing dangling stream in <TCP local=tcp://127.0.0.1:37456 remote=tcp://127.0.0.1:35009>

[CMCDragonkai]

Seems like this is related to this: #2507

[mrocklin]

In what way does with LocalCluster() not work for you? Is it just the closing dangling stream warning, or is there something else going on?

Here's my experience.

In [1]: from dask.distributed import LocalCluster

In [2]: with LocalCluster():
   ...:     pass
   ...:

In [3]:
Do you really want to exit ([y]/n)? ^D
(dev) MROCKLIN-MLT:dask mrocklin$

[CMCDragonkai]

Yes I realised, it's a #2507 problem. It's the warning that's confusing.