719735d6c5
Signed-off-by: wang.yuqi <yuqi.wang@daocloud.io> Signed-off-by: wang.yuqi <noooop@126.com> Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
124 lines
3.8 KiB
Python
124 lines
3.8 KiB
Python
# SPDX-License-Identifier: Apache-2.0
|
|
# SPDX-FileCopyrightText: Copyright contributors to the vLLM project
|
|
"""Tests for ColModernVBERT multimodal late-interaction model.
|
|
|
|
ColModernVBERT combines SigLIP vision encoder + ModernBERT text encoder
|
|
with a pixel shuffle connector and ColBERT-style 128-dim per-token
|
|
embeddings for visual document retrieval.
|
|
"""
|
|
|
|
import pytest
|
|
import torch
|
|
|
|
from vllm.entrypoints.pooling.scoring.utils import compute_maxsim_score
|
|
|
|
MODEL_NAME = "ModernVBERT/colmodernvbert-merged"
|
|
COLBERT_DIM = 128
|
|
DTYPE = "half"
|
|
# Fixme:
|
|
# Update colmodernvbert code to support the latest HF version
|
|
# and remove revision set.
|
|
REVISION = "4a0a9f3ac7a7992fec410bfa8e3d080ac9a5bcee"
|
|
|
|
|
|
# -----------------------------------------------------------------------
|
|
# Text-only tests
|
|
# -----------------------------------------------------------------------
|
|
|
|
|
|
def test_colmodernvbert_text_token_embed(vllm_runner):
|
|
"""Text query produces per-token embeddings with shape (seq_len, 128)."""
|
|
with vllm_runner(
|
|
MODEL_NAME,
|
|
revision=REVISION,
|
|
runner="pooling",
|
|
dtype=DTYPE,
|
|
enforce_eager=True,
|
|
) as vllm_model:
|
|
outputs = vllm_model.token_embed(["What is machine learning?"])
|
|
|
|
assert len(outputs) == 1
|
|
emb = torch.tensor(outputs[0])
|
|
assert emb.dim() == 2
|
|
assert emb.shape[1] == COLBERT_DIM
|
|
assert emb.shape[0] > 1
|
|
|
|
|
|
def test_colmodernvbert_text_relevance_ordering(vllm_runner):
|
|
"""Relevant documents score higher than irrelevant ones."""
|
|
query = "What is machine learning?"
|
|
documents = [
|
|
"Machine learning is a subset of artificial intelligence.",
|
|
"The weather in Paris is mild in spring.",
|
|
]
|
|
|
|
with vllm_runner(
|
|
MODEL_NAME,
|
|
revision=REVISION,
|
|
runner="pooling",
|
|
dtype=DTYPE,
|
|
enforce_eager=True,
|
|
) as vllm_model:
|
|
scores = vllm_model.score(query, documents)
|
|
|
|
assert len(scores) == 2
|
|
assert scores[0] > scores[1], "ML doc should score higher than weather doc"
|
|
|
|
|
|
def test_colmodernvbert_text_late_interaction(vllm_runner):
|
|
"""MaxSim scoring via vLLM matches manual computation."""
|
|
query = "What is the capital of France?"
|
|
doc = "The capital of France is Paris."
|
|
|
|
with vllm_runner(
|
|
MODEL_NAME,
|
|
revision=REVISION,
|
|
runner="pooling",
|
|
dtype=DTYPE,
|
|
enforce_eager=True,
|
|
) as vllm_model:
|
|
q_out = vllm_model.token_embed([query])
|
|
d_out = vllm_model.token_embed([doc])
|
|
|
|
q_emb = torch.tensor(q_out[0])
|
|
d_emb = torch.tensor(d_out[0])
|
|
manual_score = compute_maxsim_score(q_emb, d_emb).item()
|
|
|
|
vllm_scores = vllm_model.score(query, doc)
|
|
|
|
assert len(vllm_scores) == 1
|
|
assert vllm_scores[0] == pytest.approx(manual_score, rel=0.01)
|
|
|
|
|
|
# -----------------------------------------------------------------------
|
|
# Image tests
|
|
# -----------------------------------------------------------------------
|
|
|
|
|
|
def test_colmodernvbert_image_token_embed(vllm_runner, image_assets):
|
|
"""Image input produces per-token embeddings including vision tokens."""
|
|
with vllm_runner(
|
|
MODEL_NAME,
|
|
revision=REVISION,
|
|
runner="pooling",
|
|
dtype=DTYPE,
|
|
enforce_eager=True,
|
|
) as vllm_model:
|
|
image = image_assets[0].pil_image
|
|
inputs = vllm_model.get_inputs(
|
|
[""],
|
|
images=[image],
|
|
)
|
|
req_outputs = vllm_model.llm.encode(
|
|
inputs,
|
|
pooling_task="token_embed",
|
|
)
|
|
outputs = [req_output.outputs.data for req_output in req_outputs]
|
|
|
|
assert len(outputs) == 1
|
|
emb = torch.tensor(outputs[0])
|
|
assert emb.dim() == 2
|
|
assert emb.shape[1] == COLBERT_DIM
|
|
# Should have at least the image tokens (64 after pixel shuffle)
|
|
assert emb.shape[0] >= 64
|