_________________________ test_worker_start_exception __________________________

cleanup = None

    @pytest.mark.asyncio
    async def test_worker_start_exception(cleanup):
        # make sure this raises the right Exception:
        with pytest.raises(StartException):
            async with Nanny("tcp://localhost:1", worker_class=BrokenWorker) as n:
>               await n.start()
E               Failed: DID NOT RAISE <class 'test_nanny.StartException'>

distributed/tests/test_nanny.py:576: Failed
----------------------------- Captured stderr call -----------------------------
distributed.nanny - ERROR - Failed to start worker
Traceback (most recent call last):
  File "/Users/runner/work/distributed/distributed/distributed/nanny.py", line 766, in run
    await worker
  File "/Users/runner/work/distributed/distributed/distributed/core.py", line 284, in _
    await self.start()
  File "/Users/runner/work/distributed/distributed/distributed/tests/test_nanny.py", line 568, in start
    raise StartException("broken")
test_nanny.StartException: broken
distributed.nanny - ERROR - Failed to start worker
Traceback (most recent call last):
  File "/Users/runner/work/distributed/distributed/distributed/nanny.py", line 766, in run
    await worker
  File "/Users/runner/work/distributed/distributed/distributed/core.py", line 284, in _
    await self.start()
  File "/Users/runner/work/distributed/distributed/distributed/tests/test_nanny.py", line 568, in start
    raise StartException("broken")
test_nanny.StartException: broken