Skip to content

vllm.plugins.lora_resolvers.filesystem_resolver

FilesystemResolver

Bases: LoRAResolver

Source code in vllm/plugins/lora_resolvers/filesystem_resolver.py 
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
class FilesystemResolver(LoRAResolver):
    def __init__(self, lora_cache_dir: str):
        self.lora_cache_dir = lora_cache_dir

    async def resolve_lora(
        self, base_model_name: str, lora_name: str
    ) -> LoRARequest | None:
        lora_path = os.path.join(self.lora_cache_dir, lora_name)
        maybe_lora_request = await self._get_lora_req_from_path(
            lora_name, lora_path, base_model_name
        )
        return maybe_lora_request

    async def _get_lora_req_from_path(
        self, lora_name: str, lora_path: str, base_model_name: str
    ) -> LoRARequest | None:
        """Builds a LoraRequest pointing to the lora path if it's a valid
        LoRA adapter and has a matching base_model_name.
        """
        if os.path.exists(lora_path):
            adapter_config_path = os.path.join(lora_path, "adapter_config.json")

            if os.path.exists(adapter_config_path):
                with open(adapter_config_path) as file:
                    adapter_config = json.load(file)
                if (
                    adapter_config["peft_type"] == "LORA"
                    and adapter_config["base_model_name_or_path"] == base_model_name
                ):
                    lora_request = LoRARequest(
                        lora_name=lora_name,
                        lora_int_id=abs(hash(lora_name)),
                        lora_path=lora_path,
                    )
                    return lora_request
        return None

lora_cache_dir instance-attribute 

lora_cache_dir = lora_cache_dir

__init__ 

__init__(lora_cache_dir: str)
Source code in vllm/plugins/lora_resolvers/filesystem_resolver.py 
12
13
def __init__(self, lora_cache_dir: str):
    self.lora_cache_dir = lora_cache_dir

_get_lora_req_from_path async 

_get_lora_req_from_path(
    lora_name: str, lora_path: str, base_model_name: str
) -> LoRARequest | None

Builds a LoraRequest pointing to the lora path if it's a valid LoRA adapter and has a matching base_model_name.

Source code in vllm/plugins/lora_resolvers/filesystem_resolver.py 
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
async def _get_lora_req_from_path(
    self, lora_name: str, lora_path: str, base_model_name: str
) -> LoRARequest | None:
    """Builds a LoraRequest pointing to the lora path if it's a valid
    LoRA adapter and has a matching base_model_name.
    """
    if os.path.exists(lora_path):
        adapter_config_path = os.path.join(lora_path, "adapter_config.json")

        if os.path.exists(adapter_config_path):
            with open(adapter_config_path) as file:
                adapter_config = json.load(file)
            if (
                adapter_config["peft_type"] == "LORA"
                and adapter_config["base_model_name_or_path"] == base_model_name
            ):
                lora_request = LoRARequest(
                    lora_name=lora_name,
                    lora_int_id=abs(hash(lora_name)),
                    lora_path=lora_path,
                )
                return lora_request
    return None

resolve_lora async 

resolve_lora(
    base_model_name: str, lora_name: str
) -> LoRARequest | None
Source code in vllm/plugins/lora_resolvers/filesystem_resolver.py 
15
16
17
18
19
20
21
22
async def resolve_lora(
    self, base_model_name: str, lora_name: str
) -> LoRARequest | None:
    lora_path = os.path.join(self.lora_cache_dir, lora_name)
    maybe_lora_request = await self._get_lora_req_from_path(
        lora_name, lora_path, base_model_name
    )
    return maybe_lora_request

register_filesystem_resolver 

register_filesystem_resolver()

Register the filesystem LoRA Resolver with vLLM

Source code in vllm/plugins/lora_resolvers/filesystem_resolver.py 
49
50
51
52
53
54
55
56
57
58
59
60
61
62
def register_filesystem_resolver():
    """Register the filesystem LoRA Resolver with vLLM"""

    lora_cache_dir = envs.VLLM_LORA_RESOLVER_CACHE_DIR
    if lora_cache_dir:
        if not os.path.exists(lora_cache_dir) or not os.path.isdir(lora_cache_dir):
            raise ValueError(
                "VLLM_LORA_RESOLVER_CACHE_DIR must be set to a valid directory \
                for Filesystem Resolver plugin to function"
            )
        fs_resolver = FilesystemResolver(lora_cache_dir)
        LoRAResolverRegistry.register_resolver("Filesystem Resolver", fs_resolver)

    return