|
|
|
|
|
|
|
|
|
|
|
import importlib.util |
|
|
import os |
|
|
from itertools import chain |
|
|
from types import ModuleType |
|
|
from typing import Any |
|
|
|
|
|
from .logger import get_logger |
|
|
|
|
|
logger = get_logger() |
|
|
|
|
|
|
|
|
def is_vllm_available(): |
|
|
return importlib.util.find_spec('vllm') is not None |
|
|
|
|
|
|
|
|
def is_vllm_ascend_available(): |
|
|
return importlib.util.find_spec('vllm_ascend') is not None |
|
|
|
|
|
|
|
|
def is_lmdeploy_available(): |
|
|
return importlib.util.find_spec('lmdeploy') is not None |
|
|
|
|
|
|
|
|
def is_liger_available(): |
|
|
return importlib.util.find_spec('liger_kernel') is not None |
|
|
|
|
|
|
|
|
def is_swanlab_available(): |
|
|
return importlib.util.find_spec('swanlab') is not None |
|
|
|
|
|
|
|
|
def is_xtuner_available(): |
|
|
return importlib.util.find_spec('xtuner') is not None |
|
|
|
|
|
|
|
|
def is_megatron_available(): |
|
|
return importlib.util.find_spec('megatron') is not None |
|
|
|
|
|
|
|
|
def is_unsloth_available() -> bool: |
|
|
return importlib.util.find_spec('unsloth') is not None |
|
|
|
|
|
|
|
|
def is_pyreft_available() -> bool: |
|
|
return importlib.util.find_spec('pyreft') is not None |
|
|
|
|
|
|
|
|
def is_wandb_available() -> bool: |
|
|
return importlib.util.find_spec('wandb') is not None |
|
|
|
|
|
|
|
|
class _LazyModule(ModuleType): |
|
|
""" |
|
|
Module class that surfaces all objects but only performs associated imports when the objects are requested. |
|
|
""" |
|
|
|
|
|
|
|
|
|
|
|
def __init__(self, name, module_file, import_structure, module_spec=None, extra_objects=None): |
|
|
super().__init__(name) |
|
|
self._modules = set(import_structure.keys()) |
|
|
self._class_to_module = {} |
|
|
for key, values in import_structure.items(): |
|
|
for value in values: |
|
|
self._class_to_module[value] = key |
|
|
|
|
|
self.__all__ = list(import_structure.keys()) + list(chain(*import_structure.values())) |
|
|
self.__file__ = module_file |
|
|
self.__spec__ = module_spec |
|
|
self.__path__ = [os.path.dirname(module_file)] |
|
|
self._objects = {} if extra_objects is None else extra_objects |
|
|
self._name = name |
|
|
self._import_structure = import_structure |
|
|
|
|
|
|
|
|
def __dir__(self): |
|
|
result = super().__dir__() |
|
|
|
|
|
|
|
|
for attr in self.__all__: |
|
|
if attr not in result: |
|
|
result.append(attr) |
|
|
return result |
|
|
|
|
|
def __getattr__(self, name: str) -> Any: |
|
|
if name in self._objects: |
|
|
return self._objects[name] |
|
|
if name in self._modules: |
|
|
value = self._get_module(name) |
|
|
elif name in self._class_to_module.keys(): |
|
|
module = self._get_module(self._class_to_module[name]) |
|
|
value = getattr(module, name) |
|
|
else: |
|
|
raise AttributeError(f'module {self.__name__} has no attribute {name}') |
|
|
|
|
|
setattr(self, name, value) |
|
|
return value |
|
|
|
|
|
def _get_module(self, module_name: str): |
|
|
return importlib.import_module('.' + module_name, self.__name__) |
|
|
|
|
|
def __reduce__(self): |
|
|
return self.__class__, (self._name, self.__file__, self._import_structure) |
|
|
|