dask-hang.py

if __name__ == '__main__':
    import dask.distributed

    client = dask.distributed.Client()

    queue = dask.distributed.Queue('queue1')

    def f():
        return 42

    def g():
        queue
        return 42

    print(client.gather(client.compute(dask.delayed(f)())))
    # => 42
    print(client.gather(client.compute(dask.delayed(f))))
    # => <function f at 0x7f7ee5eb5730>
    print(client.gather(client.compute(dask.delayed(g)())))
    # => 42
    print(client.gather(client.compute(dask.delayed(g))))
    # => infinite hang in gather