async def METHOD_NAME(sock_dir):
    """
    Make sure timeouts work correctly
    """
    with eventpublisher_process(sock_dir):
        request = Request()
        event_listener = saltnado.EventListener(
            {},  # we don't use mod_opts, don't save?
            {"sock_dir": sock_dir, "transport": "zeromq"},
        )
        event_future = event_listener.get_event(
            request,
            tag="evt1",
            timeout=1,
        )  # get an event future
        with pytest.raises(saltnado.TimeoutException):
            await event_future  # wait for the future
        assert event_future.done()