async def METHOD_NAME():
    context = zmq.Context()
    socket = context.socket(REP)
    socket.bind(f"{SERVER_URL}:{SERVER_PORT}")
    worker_task = threading.Thread(target=worker, args=(SERVER_URL, SERVER_PORT, 1, True))
    worker_task.start()
    message = await socket.recv()
    assert message == f"READY_{HOSTNAME}".encode()
    dummy_work = {
        "@module": "tests.cli.test_distributed",
        "@class": "DummyBuilderError",
        "@version": None,
        "dummy_prechunk": False,
        "val": 0,
    }
    await socket.send(json.dumps(dummy_work).encode("utf-8"))
    await asyncio.sleep(1)
    message = await socket.recv()
    assert message.decode("utf-8") == "ERROR_Dummy error"
    worker_task.join()