wang.yuqiandgemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
05f3d714db
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>
125 lines
3.1 KiB
Python
125 lines
3.1 KiB
Python
# SPDX-License-Identifier: Apache-2.0
|
|
# SPDX-FileCopyrightText: Copyright contributors to the vLLM project
|
|
import time
|
|
from typing import Any, TypeAlias
|
|
|
|
from pydantic import (
|
|
BaseModel,
|
|
Field,
|
|
)
|
|
|
|
from vllm import PoolingParams
|
|
from vllm.config.pooler import get_use_activation
|
|
from vllm.entrypoints.openai.engine.protocol import OpenAIBaseModel, UsageInfo
|
|
from vllm.entrypoints.pooling.base.protocol import (
|
|
ClassifyRequestMixin,
|
|
PoolingBasicRequestMixin,
|
|
)
|
|
from vllm.entrypoints.pooling.score.utils import (
|
|
ScoreContentPartParam,
|
|
ScoreMultiModalParam,
|
|
)
|
|
from vllm.utils import random_uuid
|
|
|
|
|
|
class ScoreRequestMixin(PoolingBasicRequestMixin, ClassifyRequestMixin):
|
|
# --8<-- [start:score-extra-params]
|
|
mm_processor_kwargs: dict[str, Any] | None = Field(
|
|
default=None,
|
|
description=("Additional kwargs to pass to the HF processor."),
|
|
)
|
|
# --8<-- [end:score-extra-params]
|
|
|
|
def to_pooling_params(self):
|
|
return PoolingParams(
|
|
truncate_prompt_tokens=self.truncate_prompt_tokens,
|
|
use_activation=get_use_activation(self),
|
|
)
|
|
|
|
|
|
class ScoreDataRequest(ScoreRequestMixin):
|
|
data_1: list[str] | str | ScoreMultiModalParam
|
|
data_2: list[str] | str | ScoreMultiModalParam
|
|
|
|
|
|
class ScoreQueriesDocumentsRequest(ScoreRequestMixin):
|
|
queries: list[str] | str | ScoreMultiModalParam
|
|
documents: list[str] | str | ScoreMultiModalParam
|
|
|
|
@property
|
|
def data_1(self):
|
|
return self.queries
|
|
|
|
@property
|
|
def data_2(self):
|
|
return self.documents
|
|
|
|
|
|
class ScoreTextRequest(ScoreRequestMixin):
|
|
text_1: list[str] | str | ScoreMultiModalParam
|
|
text_2: list[str] | str | ScoreMultiModalParam
|
|
|
|
@property
|
|
def data_1(self):
|
|
return self.text_1
|
|
|
|
@property
|
|
def data_2(self):
|
|
return self.text_2
|
|
|
|
|
|
ScoreRequest: TypeAlias = (
|
|
ScoreQueriesDocumentsRequest | ScoreDataRequest | ScoreTextRequest
|
|
)
|
|
|
|
|
|
class RerankRequest(PoolingBasicRequestMixin, ClassifyRequestMixin):
|
|
query: str | ScoreMultiModalParam
|
|
documents: list[str] | ScoreMultiModalParam
|
|
top_n: int = Field(default_factory=lambda: 0)
|
|
|
|
# --8<-- [start:rerank-extra-params]
|
|
mm_processor_kwargs: dict[str, Any] | None = Field(
|
|
default=None,
|
|
description=("Additional kwargs to pass to the HF processor."),
|
|
)
|
|
# --8<-- [end:rerank-extra-params]
|
|
|
|
|
|
class RerankDocument(BaseModel):
|
|
text: str | None = None
|
|
multi_modal: ScoreContentPartParam | None = None
|
|
|
|
|
|
class RerankResult(BaseModel):
|
|
index: int
|
|
document: RerankDocument
|
|
relevance_score: float
|
|
|
|
|
|
class RerankUsage(BaseModel):
|
|
prompt_tokens: int
|
|
total_tokens: int
|
|
|
|
|
|
class RerankResponse(OpenAIBaseModel):
|
|
id: str
|
|
model: str
|
|
usage: RerankUsage
|
|
results: list[RerankResult]
|
|
|
|
|
|
class ScoreResponseData(OpenAIBaseModel):
|
|
index: int
|
|
object: str = "score"
|
|
score: float
|
|
|
|
|
|
class ScoreResponse(OpenAIBaseModel):
|
|
id: str = Field(default_factory=lambda: f"embd-{random_uuid()}")
|
|
object: str = "list"
|
|
created: int = Field(default_factory=lambda: int(time.time()))
|
|
model: str
|
|
data: list[ScoreResponseData]
|
|
usage: UsageInfo
|