Function api_list_record_chunks

backend/app/routes/retrieval/chunk.py:47–79

(
    request: Request,
    collection_id: str,
    record_id: str,
    data: BaseListRequest = Depends(),
    path_params: Dict = Depends(path_params_required),
    auth_info: Dict = Depends(auth_info_required),
)

    response_model=BaseListResponse,
)
async def api_list_record_chunks(
    request: Request,
    collection_id: str,
    record_id: str,
    data: BaseListRequest = Depends(),
    path_params: Dict = Depends(path_params_required),
    auth_info: Dict = Depends(auth_info_required),
):
    check_path_params(
        model_operator=chunk_ops,
        object_id_required=False,
        path_params=path_params,
    )

    data_prefix_filter = getattr(data, "prefix_filter", {})
    path_params.pop("record_id")
    prefix_filter_dict, equal_filter_dict = await validate_list_filter(chunk_ops, path_params, data_prefix_filter)
    equal_filter_dict.update({"record_id": record_id})
    chunks, has_more = await chunk_ops.list(
        collection_id=collection_id,
        limit=data.limit,
        order=data.order,
        after_id=data.after,
        before_id=data.before,
        prefix_filters=prefix_filter_dict,
        equal_filters=equal_filter_dict,
    )

    return BaseListResponse(
        data=[chunk.to_response_dict() for chunk in chunks],
        fetched_count=len(chunks),
        has_more=has_more,
    )