async def METHOD_NAME(c, s, a, pause):
    async with block_worker(c, s, a, pause):
        low = dinc(1, dask_key_name="low").persist(priority=-1)
        ev = Event()
        clog = c.submit(lambda ev: ev.wait(), ev, key="clog")
        high = dinc(2, dask_key_name="high").persist(priority=1)
    await wait(high)
    assert all(ws.processing for ws in s.workers.values())
    assert s.tasks[low.key].state == "processing"
    await ev.set()
    await wait(clog)
    await wait(low)