_____________________ test_auto_normalize_collection_sync _____________________

c = <Client: 'tcp://127.0.0.1:58347' processes=2 threads=2, memory=15.03 GB>

    def test_auto_normalize_collection_sync(c):
        da = pytest.importorskip("dask.array")
        x = da.ones(10, chunks=5)
    
        y = x.map_blocks(slowinc, delay=1, dtype=x.dtype)
        yy = c.persist(y)
    
        wait(yy)
    
        with dask.config.set(optimizations=[c._optimize_insert_futures]):
            start = time()
            y.sum().compute()
            end = time()
>           assert end - start < 1
E           assert (1594691186.7301342 - 1594691185.6998608) < 1

distributed\tests\test_client.py:4354: AssertionError