94057c3d3e
PR Test (NPU) / check-changes (push) Has been cancelled
PR Test (NPU) / pr-gate (push) Has been cancelled
PR Test (NPU) / set-image-config (push) Has been cancelled
PR Test (NPU) / stage-b-test-1-npu-a2 (0) (push) Has been cancelled
PR Test (NPU) / stage-b-test-1-npu-a2 (1) (push) Has been cancelled
PR Test (NPU) / stage-b-test-2-npu-a2 (0) (push) Has been cancelled
PR Test (NPU) / stage-b-test-2-npu-a2 (1) (push) Has been cancelled
PR Test (NPU) / stage-b-test-4-npu-a3 (push) Has been cancelled
PR Test (NPU) / stage-b-test-16-npu-a3 (push) Has been cancelled
PR Test (NPU) / multimodal-gen-test-1-npu-a3 (push) Has been cancelled
PR Test (NPU) / multimodal-gen-test-2-npu-a3 (push) Has been cancelled
PR Test (Arm64) / pr-gate (push) Has been cancelled
PR Test (Arm64) / check-changes (push) Has been cancelled
PR Test (Arm64) / build-test (push) Has been cancelled
PR Test (sgl-router) / gate (push) Has been cancelled
PR Test (sgl-router) / tier-1 — lint (push) Has been cancelled
PR Test (sgl-router) / tier-2 — build + test (push) Has been cancelled
PR Test (sgl-router) / tier-3 — docker (placeholder) (push) Has been cancelled
PR Test (sgl-router) / tier-3 — k8s integration (push) Has been cancelled
PR Test (sgl-router) / tier-3 — e2e (push) Has been cancelled
PR Test (sgl-router) / finish (push) Has been cancelled
PR Test (NPU) / single-node-poc (map[name:qwen3_6_27b_w8a8_1p_in64k_out1k_50ms runner:linux-aarch64-a3-2 test_case:test/registered/ascend/performance/qwen3_6_27b/test_npu_qwen3_6_27b_w8a8_1p_in64k_out1k_50ms.py test_type:perf]) (push) Has been cancelled
PR Test (NPU) / pr-test-npu-finish (push) Has been cancelled
PR Test (Xeon) / pr-gate (push) Has been cancelled
PR Test (Xeon) / check-changes (push) Has been cancelled
PR Test (Xeon) / build-test (, xeon-gnr, base-b-test-cpu) (push) Has been cancelled
PR Test (XPU) / check-changes (push) Has been cancelled
PR Test (XPU) / pr-gate (push) Has been cancelled
PR Test (XPU) / stage-a-test-1-gpu-xpu (push) Has been cancelled
PR Test (XPU) / wait-for-stage-a (push) Has been cancelled
PR Test (XPU) / stage-b-test-1-gpu-xpu (push) Has been cancelled
PR Test (XPU) / finish (push) Has been cancelled
CI Model Inventory / build-inventory (push) Has been cancelled
Lint / lint (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark Compilation Check (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark - Manual Policy (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark - Request Processing (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark Summary (push) Has been cancelled
PR Test (SMG) / build-wheel (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on windows (x86_64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on macos (x86_64 - auto) (push) Has been cancelled
PR Test (SMG) / python-unit-tests (push) Has been cancelled
PR Test (SMG) / unit-tests (push) Has been cancelled
PR Test (SMG) / benchmarks (push) Has been cancelled
PR Test (SMG) / chat-completions (push) Has been cancelled
PR Test (SMG) / chat-completions-4gpu (push) Has been cancelled
PR Test (SMG) / e2e (push) Has been cancelled
PR Test (SMG) / docker-build-test (push) Has been cancelled
PR Test (SMG) / k8s-integration (push) Has been cancelled
PR Test (SMG) / finish (push) Has been cancelled
PR Test (SMG) / summarize-benchmarks (push) Has been cancelled
Release SGLang Model Gateway Docker Image / publish (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on macos (aarch64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (aarch64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (x86_64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (aarch64 - musllinux_1_1) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (x86_64 - musllinux_1_1) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / Build SDist (push) Has been cancelled
Release SGLang Model Gateway to PyPI / Upload to PyPI (push) Has been cancelled
Release SGLang Kernels / build-cu129-matrix (aarch64, 12.9, 3.10, arm-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / build-cu129-matrix (x86_64, 12.9, 3.10, x64-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / release-cu129 (push) Has been cancelled
Release SGLang Kernels / build-cu130-matrix (aarch64, 13.0, 3.10, arm-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / build-cu130-matrix (x86_64, 13.0, 3.10, x64-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / release-cu130 (push) Has been cancelled
Release SGLang Kernels / build-rocm-matrix (3.10, 700) (push) Has been cancelled
Release SGLang Kernels / build-rocm-matrix (3.10, 720) (push) Has been cancelled
Release SGLang Kernels / release-rocm700 (push) Has been cancelled
Release SGLang Kernels / release-rocm720 (push) Has been cancelled
Release SGLang Kernels / build-musa43 (43, 3.10) (push) Has been cancelled
Release SGLang Kernels / release-musa43 (push) Has been cancelled
523 lines
21 KiB
Plaintext
523 lines
21 KiB
Plaintext
---
|
||
title: "How to Support New Models"
|
||
description: "This document explains how to add support for new language models and multimodal large language models (MLLMs) in SGLang. It also covers how to test new models and register external implementations."
|
||
---
|
||
This document explains how to add support for new language models and multimodal large language models (MLLMs) in
|
||
SGLang. It also covers how to test new models and register external implementations.
|
||
|
||
## How to Support a New Language Model
|
||
|
||
To support a new model in SGLang, you only need to add a single file under
|
||
the [SGLang Models Directory](https://github.com/sgl-project/sglang/tree/main/python/sglang/srt/models). You can learn
|
||
from existing model implementations and create a new file for your model. For most models, you should be able to find a
|
||
similar model to start with (e.g., starting from Llama). Also refer how
|
||
to [port a Model from vLLM to SGLang](#port-a-model-from-vllm-to-sglang)
|
||
|
||
## How to Support a New Multimodal Large Language Model
|
||
|
||
To support a new multimodal large language model (MLLM) in SGLang, there are several key components in addition to the
|
||
standard LLM support:
|
||
|
||
1. **Register your new model as multimodal**:
|
||
Extend `is_multimodal_model`
|
||
in [model_config.py](https://github.com/sgl-project/sglang/blob/0ab3f437aba729b348a683ab32b35b214456efc7/python/sglang/srt/configs/model_config.py#L561)
|
||
to return `True` for your model.
|
||
|
||
2. **Register a new chat-template**:
|
||
Only when your default chat-template is unable to accept images as input: Register a new chat template in [conversation.py](https://github.com/sgl-project/sglang/blob/main/python/sglang/srt/parser/conversation.py) and the corresponding matching function.
|
||
|
||
3. **Multimodal Data Processor**:
|
||
Define a new `Processor` class that inherits from `BaseMultimodalProcessor` and register this processor as your
|
||
model’s dedicated processor.
|
||
See [multimodal_processor.py](https://github.com/sgl-project/sglang/tree/main/python/sglang/srt/multimodal/processors)
|
||
for more details.
|
||
|
||
4. **Handle Multimodal Tokens**:
|
||
Implement a `pad_input_ids` function for your new model. In this function, multimodal tokens in the prompt should be
|
||
expanded (if necessary) and padded with multimodal-data-hashes so that SGLang can recognize different multimodal data
|
||
with `RadixAttention`.
|
||
|
||
5. **Handle Image Feature Extraction**:
|
||
Implement a `get_image_feature` function for your new model, which extracts image features from raw image data and converts them into the embeddings used by the language model.
|
||
|
||
6. **Adapt to Vision Attention**:
|
||
Adapt the multi-headed `Attention` of ViT with SGLang’s `VisionAttention`.
|
||
|
||
You can refer to [Qwen2VL](https://github.com/sgl-project/sglang/blob/main/python/sglang/srt/models/qwen2_vl.py) or
|
||
other mllm implementations. These models demonstrate how to correctly handle both multimodal and textual inputs.
|
||
|
||
## Testing and Debugging
|
||
|
||
Please note all your testing and benchmarking results in PR description.
|
||
|
||
### Interactive Debugging
|
||
|
||
For interactive debugging, compare the outputs of Hugging Face/Transformers and SGLang. The following two commands
|
||
should give the same text output and very similar prefill logits:
|
||
|
||
- Get the reference output:
|
||
```bash Command
|
||
python3 scripts/playground/reference_hf.py --model-path [new model] --model-type {text,vlm}
|
||
```
|
||
- Get the SGLang output:
|
||
```bash Command
|
||
python3 -m sglang.bench_one_batch --correct --model [new model]
|
||
```
|
||
|
||
### Add the Model to the Test Suite
|
||
|
||
To ensure the new model is well maintained, add it to the test suite by including it in the `ALL_OTHER_MODELS` list in
|
||
the [test_generation_models.py](https://github.com/sgl-project/sglang/blob/main/test/registered/models/test_generation_models.py)
|
||
file, test the new model on your local machine and report the results on demonstrative benchmarks (GSM8K, MMLU, MMMU,
|
||
MMMU-Pro, etc.) in your PR. \\
|
||
For VLMs, also include a test in `test_vision_openai_server_{x}.py` (e.g. [test_vision_openai_server_a.py](https://github.com/sgl-project/sglang/blob/main/test/registered/vlm/test_vision_openai_server_a.py)).
|
||
|
||
This is an example command to run to test a new model on your local machine:
|
||
|
||
```bash Run Test
|
||
ONLY_RUN=Qwen/Qwen2-1.5B python3 -m unittest test_generation_models.TestGenerationModels.test_others
|
||
```
|
||
|
||
### Benchmark
|
||
|
||
- **(Required) MMMU**: follow MMMU benchmark [README.md](https://github.com/sgl-project/sglang/blob/main/benchmark/mmmu/README.md) to get SGLang vs. HF Transformer accuracy comparison. The accuracy score from SGLang run should not be much lower than that from HF Transformer run. Similarly, follow https://docs.sglang.io/developer_guide/benchmark_and_profiling.html to get performance comparison: TTFT and throughput must meet or exceed baselines (e.g., HF Transformer).
|
||
- **(Optional) Other evals**: If you ran other evals, please note the results in PR description.
|
||
|
||
## Port a Model from vLLM to SGLang
|
||
|
||
The [vLLM Models Directory](https://github.com/vllm-project/vllm/tree/main/vllm/model_executor/models) is a valuable
|
||
resource, as vLLM covers many models. SGLang reuses vLLM’s interface and some layers, making it easier to port models
|
||
from vLLM to SGLang.
|
||
|
||
To port a model from vLLM to SGLang:
|
||
|
||
- Compare these two files for guidance:
|
||
- [SGLang Llama Implementation](https://github.com/sgl-project/sglang/blob/main/python/sglang/srt/models/llama.py)
|
||
- [vLLM Llama Implementation](https://github.com/vllm-project/vllm/blob/main/vllm/model_executor/models/llama.py)
|
||
- The major differences include:
|
||
- **Replace vLLM’s `Attention` with `RadixAttention`** (ensure you pass `layer_id` to `RadixAttention`).
|
||
- **Replace vLLM’s `LogitsProcessor` with SGLang’s `LogitsProcessor`.**
|
||
- **Replace the multi-headed `Attention` of ViT with SGLang’s `VisionAttention`.**
|
||
- **Replace other vLLM layers** (such as `RMSNorm`, `SiluAndMul`) with SGLang layers.
|
||
- **Remove `Sample`.**
|
||
- **Change the `forward()` functions** and add a `forward_batch()` method.
|
||
- **Add `EntryClass`** at the end.
|
||
- **Ensure that the new implementation uses only SGLang components** and does not rely on any vLLM components.
|
||
|
||
Note: make sure you add your new model to the supported models list in the supported models documentation.
|
||
|
||
## Registering an External Model Implementation
|
||
|
||
In addition to the methods above, you can register your new model with the `ModelRegistry` before launching the server.
|
||
This allows you to integrate your model without modifying the source code.
|
||
|
||
For example:
|
||
|
||
```python Register Model
|
||
from sglang.srt.models.registry import ModelRegistry
|
||
from sglang.srt.entrypoints.http_server import launch_server
|
||
|
||
# For a single model, add it to the registry:
|
||
ModelRegistry.models[model_name] = model_class
|
||
|
||
# For multiple models, you can imitate the import_model_classes() function:
|
||
from functools import lru_cache
|
||
|
||
@lru_cache()
|
||
def import_new_model_classes():
|
||
model_arch_name_to_cls = {}
|
||
# Populate model_arch_name_to_cls with your new model classes.
|
||
...
|
||
return model_arch_name_to_cls
|
||
|
||
ModelRegistry.models.update(import_new_model_classes())
|
||
|
||
# Launch the server with your server arguments:
|
||
launch_server(server_args)
|
||
```
|
||
|
||
## Example: Implementing and Serving a Llama Wrapper Model
|
||
|
||
Below is an introductory, step-by-step walkthrough on how to implement a new model end-to-end in SGLang and then run it via the [Offline Engine](../basic_usage/offline_engine_api).
|
||
|
||
### Implementing Our Model
|
||
|
||
To keep things simple, this new model will be a simple wrapper around [Llama 3.1-8B-Instruct](https://huggingface.co/meta-llama/Llama-3.1-8B-Instruct), and our goal will be just to bias the output logits for each `forward` call by taking the square root of each individual logit.
|
||
|
||
Let's start by defining our model in a file called `llama_wrapper.py`.
|
||
The first step is to import the necessary libraries from SRT, which is SGLang's internal backend.
|
||
|
||
```python Example
|
||
# In the file `llama_wrapper.py`
|
||
|
||
import torch
|
||
from transformers import LlamaConfig
|
||
from typing import Optional
|
||
from sglang.srt.layers.logits_processor import LogitsProcessorOutput
|
||
from sglang.srt.layers.quantization.base_config import QuantizationConfig
|
||
from sglang.srt.model_executor.forward_batch_info import ForwardBatch, PPProxyTensors
|
||
|
||
from sglang.srt.models.llama import LlamaForCausalLM
|
||
```
|
||
|
||
Next, we declare a new `class` for our model and have it inherit from `LlamaForCausalLM`, which allows our model to access `LlamaForCausalLM`'s predefined modules and layers, such as `LlamaAttention` and `LlamaMLP`.
|
||
Note that almost all model implementations take in `config` and `quant_config` as arguments for their `__init__` method; `config` and `quant_config` are passed in via [`model_loader/loader.py`](https://github.com/sgl-project/sglang/blob/bf72b80122fd888bf619d17b96fa3e323ab809fc/python/sglang/srt/model_loader/loader.py#L219).
|
||
Because we have inherited from `LlamaForCausalLM`, we can pass our parameters directly to its constructor, which will set the member variables for us.
|
||
|
||
```python Class Definition
|
||
class LlamaWrapper(LlamaForCausalLM):
|
||
def __init__(
|
||
self,
|
||
config: LlamaConfig,
|
||
quant_config: Optional[QuantizationConfig] = None,
|
||
prefix: str = "",
|
||
) -> None:
|
||
super().__init__(config=config, quant_config=quant_config, prefix=prefix)
|
||
```
|
||
|
||
Now, we want to define the `forward` method, which is what will be called at inference time.
|
||
Note that the signature for `forward` is essentially the same for any model; you can take a look at the other models defined in the [`models` directory](https://github.com/sgl-project/sglang/blob/main/python/sglang/srt/models/) for references.
|
||
To see where exactly `forward` is called in the SGLang runtime's internals, take a look at [`forward_decode`](https://github.com/sgl-project/sglang/blob/bf72b80122fd888bf619d17b96fa3e323ab809fc/python/sglang/srt/model_executor/model_runner.py#L1705) and [`forward_extend`](https://github.com/sgl-project/sglang/blob/bf72b80122fd888bf619d17b96fa3e323ab809fc/python/sglang/srt/model_executor/model_runner.py#L1724) in the [`ModelRunner` class](https://github.com/sgl-project/sglang/blob/main/python/sglang/srt/model_executor/model_runner.py).
|
||
|
||
```python Forward Method Signature
|
||
@torch.no_grad()
|
||
def forward(
|
||
self,
|
||
input_ids: torch.Tensor,
|
||
positions: torch.Tensor,
|
||
forward_batch: ForwardBatch,
|
||
pp_proxy_tensors: Optional[PPProxyTensors] = None,
|
||
input_embeds: Optional[torch.Tensor] = None,
|
||
get_embedding: bool = False,
|
||
) -> LogitsProcessorOutput:
|
||
```
|
||
|
||
We now call the `__call__` method for `self.model` (which is a member variable that `LlamaForCausalLM` defines in its `__init__` method), which eventually calls `LlamaForCausalLM`'s `forward` method.
|
||
After that, we feed the `hidden_states` into our model's `LogitsProcessor` (again defined in `LlamaForCausalLM`).
|
||
|
||
```python Call Model and LogitsProcessor
|
||
hidden_states = self.model(
|
||
input_ids,
|
||
positions,
|
||
forward_batch,
|
||
input_embeds,
|
||
pp_proxy_tensors=pp_proxy_tensors,
|
||
)
|
||
|
||
res: LogitsProcessorOutput = self.logits_processor(
|
||
input_ids,
|
||
hidden_states,
|
||
self.lm_head,
|
||
forward_batch,
|
||
)
|
||
```
|
||
|
||
After receiving the logits for the next token, we can finally perform our biasing step.
|
||
|
||
```python Logit Biasing
|
||
orig_logits = res.next_token_logits
|
||
res.next_token_logits = torch.where(
|
||
orig_logits > 0,
|
||
orig_logits.sqrt(),
|
||
orig_logits
|
||
)
|
||
|
||
return res
|
||
```
|
||
|
||
Now, our `LlamaWrapper` model is created and ready to be served!
|
||
|
||
### Serving Our Model Via SGLang's Offline Engine
|
||
|
||
The next step of this walkthrough involves hosting our new model offline, so that it can be served locally and without an HTTP server.
|
||
|
||
First, create a new file called `run.py`.
|
||
Now, we must ensure that SGLang's `ModelRegistry` can find our model.
|
||
To do this, we first download the model's configuration and weights from Huggingface.
|
||
|
||
```python Example
|
||
# In the file `run.py`
|
||
|
||
import asyncio
|
||
from functools import lru_cache
|
||
from huggingface_hub import snapshot_download
|
||
from llama_wrapper import LlamaWrapper # Make sure to import our new model!
|
||
import sglang as sgl
|
||
from sglang.srt.models.registry import ModelRegistry
|
||
|
||
# Make sure to request access to this model on Huggingface, then export your
|
||
# `HF_TOKEN` to download the model snapshot
|
||
llama_dir = snapshot_download(
|
||
repo_id="meta-llama/Llama-3.1-8B-Instruct",
|
||
local_dir="./llama_ckpt",
|
||
)
|
||
```
|
||
|
||
Now that we have our model on disk, we want to point it to `LlamaWrapper` by changing the `architectures` field in `./llama_ckpt/config.json` to be `LlamaWrapper`.
|
||
That way, when we pass in the path of our model checkpoint to SGLang, it will know that we want to use "LlamaWrapper" instead of "LlamaForCausalLM" as our model.
|
||
|
||
```python Example
|
||
{
|
||
"architectures": [
|
||
# "LlamaForCausalLM"
|
||
"LlamaWrapper"
|
||
],
|
||
...
|
||
}
|
||
```
|
||
|
||
However, if we don't link our `LlamaWrapper` class to the "LlamaWrapper" registry keyword, then SGLang won't be able to find our model.
|
||
Thus, to register our `LlamaWrapper`, we want to follow the steps in the above section titled "Registering an External Model Implementation".
|
||
|
||
```python Register LlamaWrapper
|
||
@lru_cache()
|
||
def import_new_model_classes():
|
||
model_arch_name_to_cls = {"LlamaWrapper": LlamaWrapper}
|
||
return model_arch_name_to_cls
|
||
|
||
ModelRegistry.models.update(import_new_model_classes())
|
||
```
|
||
|
||
Lastly, when we create our `Engine`, we just pass in the path to the local model directory.
|
||
Then, our `LlamaWrapper` is ready to be served; for this walkthrough, we will use SGLang `Engine`'s non-streaming asynchronous generation endpoint.
|
||
|
||
```python Example
|
||
def main():
|
||
llm = sgl.Engine(model_path="./llama_ckpt")
|
||
sampling_params = {"temperature": 0.2, "top_k": 5}
|
||
prompts = [
|
||
"Write a short, neutral self-introduction for a fictional character. Hello, my name is",
|
||
"Provide a concise factual statement about France’s capital city. The capital of France is",
|
||
"Explain possible future trends in artificial intelligence. The future of AI is",
|
||
]
|
||
|
||
asyncio.run(run_llm(llm, sampling_params, prompts))
|
||
|
||
llm.shutdown()
|
||
|
||
async def run_llm(
|
||
llm,
|
||
sampling_params,
|
||
prompts,
|
||
) -> None:
|
||
outputs = await llm.async_generate(prompts, sampling_params)
|
||
|
||
for prompt, output in zip(prompts, outputs):
|
||
print(f"\nPrompt: {prompt}")
|
||
print(f"Generated text: {output['text']}")
|
||
|
||
if __name__ == "__main__":
|
||
main()
|
||
```
|
||
|
||
Now, when we call `python run.py`, we will get the outputs of our newly created model!
|
||
|
||
## Serving External Models via the Standard CLI
|
||
|
||
The previous sections show how to register a model programmatically via `ModelRegistry` and serve it through the Offline Engine. Similar to vLLM model plugin, there is an alternative that lets you keep using the standard `python -m sglang.launch_server` CLI without modifying any SGLang source code: you can register your model using the `SGLANG_EXTERNAL_MODEL_PACKAGE` environment variable.
|
||
|
||
### The `EntryClass` Variable
|
||
|
||
When SGLang scans a model package, it looks for the variable `EntryClass` at the module level of your Python file. The [model registry](https://github.com/sgl-project/sglang/blob/main/python/sglang/srt/models/registry.py) imports your file, checks for `EntryClass`, and registers the class assigned to it. If you are using a model based on HuggingFace, the name of this class needs to match the `"architectures"` field in your model's `config.json`.
|
||
|
||
For example, if you are implementing a Llama wrapper, add this line at the end of your model file:
|
||
|
||
```python Example
|
||
# This is what "Add EntryClass at the end" means
|
||
EntryClass = LlamaWrapper
|
||
```
|
||
|
||
### Example: Text-Only Model
|
||
|
||
Using the same Llama wrapper from the previous section, here is how to package and serve it via the CLI.
|
||
|
||
1. Create your project
|
||
|
||
```
|
||
sglang_custom_project/
|
||
|----setup.py
|
||
|----custom_llm/
|
||
|----__init__.py
|
||
|----llama_wrapper.py
|
||
```
|
||
|
||
Write the `setup.py`:
|
||
|
||
```python Example
|
||
# sglang_custom_project/setup.py
|
||
|
||
from setuptools import setup, find_packages
|
||
setup(
|
||
name="sglang-custom-plugins",
|
||
version="0.1",
|
||
packages=find_packages(),
|
||
)
|
||
```
|
||
|
||
2. Write your model code
|
||
|
||
Inside `llama_wrapper.py`, write your model and include `EntryClass`:
|
||
|
||
```python Example
|
||
# sglang_custom_project/custom_llm/llama_wrapper.py
|
||
|
||
import torch
|
||
from typing import Optional
|
||
from sglang.srt.layers.logits_processor import LogitsProcessorOutput
|
||
from sglang.srt.layers.quantization.base_config import QuantizationConfig
|
||
from sglang.srt.model_executor.forward_batch_info import ForwardBatch, PPProxyTensors
|
||
from sglang.srt.models.llama import LlamaForCausalLM
|
||
|
||
class LlamaWrapper(LlamaForCausalLM):
|
||
def __init__(self, config, quant_config: Optional[QuantizationConfig] = None,
|
||
prefix: str = "") -> None:
|
||
super().__init__(config=config, quant_config=quant_config, prefix=prefix)
|
||
@torch.no_grad()
|
||
def forward(self, input_ids, positions, forward_batch,
|
||
pp_proxy_tensors=None, input_embeds=None, get_embedding=False):
|
||
hidden_states = self.model(
|
||
input_ids, positions, forward_batch, input_embeds,
|
||
pp_proxy_tensors=pp_proxy_tensors,
|
||
)
|
||
res: LogitsProcessorOutput = self.logits_processor(
|
||
input_ids, hidden_states, self.lm_head, forward_batch,
|
||
)
|
||
|
||
orig = res.next_token_logits
|
||
res.next_token_logits = torch.where(orig > 0, orig.sqrt(), orig)
|
||
return res
|
||
|
||
# Don't forget to add EntryClass
|
||
EntryClass = LlamaWrapper
|
||
```
|
||
|
||
3. Install your package
|
||
|
||
Run this inside your `sglang_custom_project` directory to install your code into the active Python environment:
|
||
|
||
```bash Command
|
||
pip install -e .
|
||
```
|
||
|
||
4. Update your `config.json`
|
||
|
||
Update the `config.json` under your HuggingFace model checkpoint directory so the `architectures` field matches your class name:
|
||
|
||
```json Config
|
||
{
|
||
"architectures": ["LlamaWrapper"],
|
||
...
|
||
}
|
||
```
|
||
|
||
5. Launch the server
|
||
|
||
Set the environment variable before running the CLI:
|
||
|
||
```bash Command
|
||
export SGLANG_EXTERNAL_MODEL_PACKAGE=custom_llm
|
||
python -m sglang.launch_server \
|
||
--model-path /path/to/Llama-3.1-8B-Instruct \
|
||
--port 8000
|
||
```
|
||
|
||
The `SGLANG_EXTERNAL_MODEL_PACKAGE` should be the parent folder name containing your model-related code. In this example, it should be `custom_llm`.
|
||
|
||
### Example: Multimodal Model
|
||
|
||
If you are working with multimodal models, setting `SGLANG_EXTERNAL_MODEL_PACKAGE` alone is not enough. SGLang also needs to recognize your architecture as multimodal to enable the image/video processing pipelines, and it needs a custom processor.
|
||
|
||
You can handle this by setting two additional environment variables:
|
||
|
||
- `SGLANG_EXTERNAL_MM_MODEL_ARCH`: Adds your architecture name to SGLang's internal list of multimodal models.
|
||
- `SGLANG_EXTERNAL_MM_PROCESSOR_PACKAGE`: Tells SGLang where to find your custom processor class.
|
||
|
||
For example, let's build a custom model based on Qwen2-VL-Instruct that takes the square root of the logits.
|
||
|
||
Create the project:
|
||
|
||
```
|
||
sglang_custom_project_vl/
|
||
|----setup.py
|
||
|----custom_vlm/
|
||
|----__init__.py
|
||
|----qwenvl_wrapper.py
|
||
```
|
||
|
||
Write `setup.py`:
|
||
|
||
```python Example
|
||
# sglang_custom_project_vl/setup.py
|
||
|
||
from setuptools import setup, find_packages
|
||
setup(
|
||
name="sglang-custom-plugins-vl",
|
||
version="0.1",
|
||
packages=find_packages(),
|
||
)
|
||
```
|
||
|
||
Write the model in `qwenvl_wrapper.py`:
|
||
|
||
```python Example
|
||
# sglang_custom_project_vl/custom_vlm/qwenvl_wrapper.py
|
||
import torch
|
||
from sglang.srt.models.qwen2_vl import Qwen2VLForConditionalGeneration
|
||
from sglang.srt.multimodal.processors.qwen_vl import QwenVLImageProcessor
|
||
|
||
class CustomQwen2VL(Qwen2VLForConditionalGeneration):
|
||
def forward(self, input_ids, positions, forward_batch,
|
||
input_embeds=None, get_embedding=False):
|
||
res = super().forward(
|
||
input_ids, positions, forward_batch,
|
||
input_embeds=input_embeds, get_embedding=get_embedding
|
||
)
|
||
if not get_embedding:
|
||
orig = res.next_token_logits
|
||
res.next_token_logits = torch.where(orig > 0, orig.sqrt(), orig)
|
||
return res
|
||
|
||
class CustomQwen2VLProcessor(QwenVLImageProcessor):
|
||
models = [CustomQwen2VL]
|
||
|
||
def __init__(self, hf_config, server_args, _processor, *args, **kwargs):
|
||
super().__init__(hf_config, server_args, _processor, *args, **kwargs)
|
||
|
||
EntryClass = CustomQwen2VL
|
||
```
|
||
|
||
**Note:** you don't need a separate `EntryClass` for the custom processor as long as you associate the processor with the specific model class.
|
||
|
||
Install the package, update `config.json`, and launch:
|
||
|
||
```bash Command
|
||
pip install -e .
|
||
```
|
||
|
||
```json Config
|
||
{
|
||
"architectures": ["CustomQwen2VL"],
|
||
...
|
||
}
|
||
```
|
||
|
||
```bash Command
|
||
export SGLANG_EXTERNAL_MODEL_PACKAGE=custom_vlm
|
||
export SGLANG_EXTERNAL_MM_MODEL_ARCH=CustomQwen2VL
|
||
export SGLANG_EXTERNAL_MM_PROCESSOR_PACKAGE=custom_vlm
|
||
|
||
python -m sglang.launch_server \
|
||
--model-path /path/to/Qwen2-VL-2B-Instruct \
|
||
--port 8000 \
|
||
--enable-multimodal
|
||
```
|
||
|
||
## Documentation
|
||
|
||
Add to table of supported models in [generative_models.md](./generative_models) or [multimodal_language_models.md](./multimodal_language_models)
|
||
|
||
---
|
||
|
||
By following these guidelines, you can add support for new language models and multimodal large language models in
|
||
SGLang and ensure they are thoroughly tested and easily integrated into the system.
|