______________________________ test_lots_of_tasks ______________________________

c = <Client: No scheduler connected>
s = <Scheduler 'tcp://127.0.0.1:52907', workers: 0, cores: 0, tasks: 0>
a = <Worker 'tcp://127.0.0.1:52908', name: 0, status: closed, stored: 0, running: 0/1, ready: 0, comm: 0, waiting: 0>
b = <Worker 'tcp://127.0.0.1:52910', name: 1, status: closed, stored: 0, running: 0/2, ready: 0, comm: 0, waiting: 0>

    @gen_cluster(
        client=True,
        scheduler_kwargs={"dashboard": True},
        config={
            "distributed.scheduler.dashboard.tasks.task-stream-length": 10,
            "distributed.scheduler.dashboard.status.task-stream-length": 10,
        },
    )
    async def test_lots_of_tasks(c, s, a, b):
        import tlz as toolz
    
        ts = TaskStream(s)
        ts.update()
        futures = c.map(toolz.identity, range(100))
        await wait(futures)
    
        tsp = s.plugins[TaskStreamPlugin.name]
        assert len(tsp.buffer) == 10
        ts.update()
>       assert len(ts.source.data["start"]) == 10
E       assert 11 == 10
E        +  where 11 = len(array([ 1.54638672,  0.        ,  0.99829102,  7.20776367,  5.12182617,\n        6.47998047, 83.5144043 , 49.33178711, 79.44384766, 82.61474609,\n       89.00756836]))

distributed/dashboard/tests/test_scheduler_bokeh.py:873: AssertionError