async def METHOD_NAME(req: Request, ws: Websocket):
    amodel = await _prepare_websocket_amodel(req, ws, ConcActionModel, 0)
    while True:
        try:
            response = await _get_conc_cache_status(amodel)
        except Exception as e:
            await ws.close(code=1011, reason=str(e))
        await ws.send(json.dumps(response))
        if response['finished']:
            await ws.close()
        else:
            await asyncio.sleep(WEBSOCKET_CONC_CHECK_INTERVAL)