Function cancel_request

api_utils/routers/queue.py:36–57

(
    req_id: str,
    logger: logging.Logger = Depends(get_logger),
    request_queue: Queue = Depends(get_request_queue),
)

async def cancel_request(
    req_id: str,
    logger: logging.Logger = Depends(get_logger),
    request_queue: Queue = Depends(get_request_queue),
):
    set_request_id(req_id)
    logger.info("Received cancellation request.")
    if await cancel_queued_request(req_id, request_queue, logger):
        return JSONResponse(
            content={
                "success": True,
                "message": f"Request {req_id} marked as cancelled.",
            }
        )
    else:
        return JSONResponse(
            status_code=404,
            content={
                "success": False,
                "message": f"Request {req_id} not found in queue.",
            },
        )


async def get_queue_status(