async def METHOD_NAME(event_type: Type[Event], timeout: float):
    e = await eventually(events, lambda e: isinstance(e, event_type), timeout)
    assert e, f"Timed out waiting for {event_type}"
    logger.info(colors.cyan(str(e)))
    return e