| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| import inspect |
| from typing import Optional |
|
|
| from ..utils import ( |
| check_peft_version, |
| find_adapter_config_file, |
| is_accelerate_available, |
| is_peft_available, |
| logging, |
| ) |
|
|
|
|
| if is_accelerate_available(): |
| from accelerate import dispatch_model |
| from accelerate.utils import get_balanced_memory, infer_auto_device_map |
|
|
| |
| MIN_PEFT_VERSION = "0.5.0" |
|
|
| logger = logging.get_logger(__name__) |
|
|
|
|
| class PeftAdapterMixin: |
| """ |
| A class containing all functions for loading and using adapters weights that are supported in PEFT library. For |
| more details about adapters and injecting them on a transformer-based model, check out the documentation of PEFT |
| library: https://huggingface.co/docs/peft/index |
| |
| Currently supported PEFT methods are all non-prefix tuning methods. Below is the list of supported PEFT methods |
| that anyone can load, train and run with this mixin class: |
| - Low Rank Adapters (LoRA): https://huggingface.co/docs/peft/conceptual_guides/lora |
| - IA3: https://huggingface.co/docs/peft/conceptual_guides/ia3 |
| - AdaLora: https://arxiv.org/abs/2303.10512 |
| |
| Other PEFT models such as prompt tuning, prompt learning are out of scope as these adapters are not "injectable" |
| into a torch module. For using these methods, please refer to the usage guide of PEFT library. |
| |
| With this mixin, if the correct PEFT version is installed, it is possible to: |
| |
| - Load an adapter stored on a local path or in a remote Hub repository, and inject it in the model |
| - Attach new adapters in the model and train them with Trainer or by your own. |
| - Attach multiple adapters and iteratively activate / deactivate them |
| - Activate / deactivate all adapters from the model. |
| - Get the `state_dict` of the active adapter. |
| """ |
|
|
| _hf_peft_config_loaded = False |
|
|
| def load_adapter( |
| self, |
| peft_model_id: str, |
| adapter_name: Optional[str] = None, |
| revision: Optional[str] = None, |
| token: Optional[str] = None, |
| device_map: Optional[str] = "auto", |
| max_memory: Optional[str] = None, |
| offload_folder: Optional[str] = None, |
| offload_index: Optional[int] = None, |
| ) -> None: |
| """ |
| Load adapter weights from file or remote Hub folder. If you are not familiar with adapters and PEFT methods, we |
| invite you to read more about them on PEFT official documentation: https://huggingface.co/docs/peft |
| |
| Requires peft as a backend to load the adapter weights. |
| |
| Args: |
| peft_model_id (`str`): |
| The identifier of the model to look for on the Hub, or a local path to the saved adapter config file |
| and adapter weights. |
| adapter_name (`str`, *optional*): |
| The adapter name to use. If not set, will use the default adapter. |
| revision (`str`, *optional*, defaults to `"main"`): |
| The specific model version to use. It can be a branch name, a tag name, or a commit id, since we use a |
| git-based system for storing models and other artifacts on huggingface.co, so `revision` can be any |
| identifier allowed by git. |
| |
| <Tip> |
| |
| To test a pull request you made on the Hub, you can pass `revision="refs/pr/<pr_number>". |
| |
| </Tip> |
| |
| token (`str`, `optional`): |
| Whether to use authentication token to load the remote folder. Userful to load private repositories |
| that are on HuggingFace Hub. You might need to call `huggingface-cli login` and paste your tokens to |
| cache it. |
| device_map (`str` or `Dict[str, Union[int, str, torch.device]]` or `int` or `torch.device`, *optional*): |
| A map that specifies where each submodule should go. It doesn't need to be refined to each |
| parameter/buffer name, once a given module name is inside, every submodule of it will be sent to the |
| same device. If we only pass the device (*e.g.*, `"cpu"`, `"cuda:1"`, `"mps"`, or a GPU ordinal rank |
| like `1`) on which the model will be allocated, the device map will map the entire model to this |
| device. Passing `device_map = 0` means put the whole model on GPU 0. |
| |
| To have Accelerate compute the most optimized `device_map` automatically, set `device_map="auto"`. For |
| more information about each option see [designing a device |
| map](https://hf.co/docs/accelerate/main/en/usage_guides/big_modeling#designing-a-device-map). |
| max_memory (`Dict`, *optional*): |
| A dictionary device identifier to maximum memory. Will default to the maximum memory available for each |
| GPU and the available CPU RAM if unset. |
| offload_folder (`str` or `os.PathLike`, `optional`): |
| If the `device_map` contains any value `"disk"`, the folder where we will offload weights. |
| offload_index (`int`, `optional`): |
| `offload_index` argument to be passed to `accelerate.dispatch_model` method. |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
|
|
| adapter_name = adapter_name if adapter_name is not None else "default" |
|
|
| from peft import PeftConfig, inject_adapter_in_model, load_peft_weights |
| from peft.utils import set_peft_model_state_dict |
|
|
| if not self._hf_peft_config_loaded: |
| self._hf_peft_config_loaded = True |
| elif adapter_name in self.peft_config: |
| raise ValueError(f"Adapter with name {adapter_name} already exists. Please use a different name.") |
|
|
| adapter_config_file = find_adapter_config_file( |
| peft_model_id, |
| revision=revision, |
| token=token, |
| ) |
|
|
| if adapter_config_file is None: |
| raise ValueError( |
| f"adapter model file not found in {peft_model_id}. Make sure you are passing the correct path to the " |
| "adapter model." |
| ) |
|
|
| loaded_peft_config = PeftConfig.from_pretrained( |
| peft_model_id, |
| revision=revision, |
| use_auth_token=token, |
| ) |
|
|
| |
| inject_adapter_in_model(loaded_peft_config, self, adapter_name) |
|
|
| adapter_state_dict = load_peft_weights(peft_model_id, revision=revision, use_auth_token=token) |
|
|
| |
| processed_adapter_state_dict = {} |
| prefix = "base_model.model." |
| for key, value in adapter_state_dict.items(): |
| if key.startswith(prefix): |
| new_key = key[len(prefix) :] |
| else: |
| new_key = key |
| processed_adapter_state_dict[new_key] = value |
|
|
| |
| incompatible_keys = set_peft_model_state_dict(self, processed_adapter_state_dict, adapter_name) |
|
|
| if incompatible_keys is not None: |
| |
| if hasattr(incompatible_keys, "unexpected_keys") and len(incompatible_keys.unexpected_keys) > 0: |
| logger.warning( |
| f"Loading adapter weights from {peft_model_id} led to unexpected keys not found in the model: " |
| f" {incompatible_keys.unexpected_keys}. " |
| ) |
|
|
| |
| if ( |
| (getattr(self, "hf_device_map", None) is not None) |
| and (len(set(self.hf_device_map.values()).intersection({"cpu", "disk"})) > 0) |
| and len(self.peft_config) == 1 |
| ): |
| self._dispatch_accelerate_model( |
| device_map=device_map, |
| max_memory=max_memory, |
| offload_folder=offload_folder, |
| offload_index=offload_index, |
| ) |
|
|
| def add_adapter(self, adapter_config, adapter_name: Optional[str] = None) -> None: |
| r""" |
| If you are not familiar with adapters and PEFT methods, we invite you to read more about them on the PEFT |
| official documentation: https://huggingface.co/docs/peft |
| |
| Adds a fresh new adapter to the current model for training purpose. If no adapter name is passed, a default |
| name is assigned to the adapter to follow the convention of PEFT library (in PEFT we use "default" as the |
| default adapter name). |
| |
| Args: |
| adapter_config (`~peft.PeftConfig`): |
| The configuration of the adapter to add, supported adapters are non-prefix tuning and adaption prompts |
| methods |
| adapter_name (`str`, *optional*, defaults to `"default"`): |
| The name of the adapter to add. If no name is passed, a default name is assigned to the adapter. |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
|
|
| from peft import PeftConfig, inject_adapter_in_model |
|
|
| adapter_name = adapter_name or "default" |
|
|
| if not self._hf_peft_config_loaded: |
| self._hf_peft_config_loaded = True |
| elif adapter_name in self.peft_config: |
| raise ValueError(f"Adapter with name {adapter_name} already exists. Please use a different name.") |
|
|
| if not isinstance(adapter_config, PeftConfig): |
| raise ValueError( |
| f"adapter_config should be an instance of PeftConfig. Got {type(adapter_config)} instead." |
| ) |
|
|
| |
| |
| adapter_config.base_model_name_or_path = self.__dict__.get("name_or_path", None) |
| inject_adapter_in_model(adapter_config, self, adapter_name) |
|
|
| self.set_adapter(adapter_name) |
|
|
| def set_adapter(self, adapter_name: str) -> None: |
| """ |
| If you are not familiar with adapters and PEFT methods, we invite you to read more about them on the PEFT |
| official documentation: https://huggingface.co/docs/peft |
| |
| Sets a specific adapter by forcing the model to use a that adapter and disable the other adapters. |
| |
| Args: |
| adapter_name (`str`): |
| The name of the adapter to set. |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
| if not self._hf_peft_config_loaded: |
| raise ValueError("No adapter loaded. Please load an adapter first.") |
| elif adapter_name not in self.peft_config: |
| raise ValueError( |
| f"Adapter with name {adapter_name} not found. Please pass the correct adapter name among {list(self.peft_config.keys())}" |
| ) |
|
|
| from peft.tuners.tuners_utils import BaseTunerLayer |
|
|
| _adapters_has_been_set = False |
|
|
| for _, module in self.named_modules(): |
| if isinstance(module, BaseTunerLayer): |
| module.active_adapter = adapter_name |
| _adapters_has_been_set = True |
|
|
| if not _adapters_has_been_set: |
| raise ValueError( |
| "Did not succeeded in setting the adapter. Please make sure you are using a model that supports adapters." |
| ) |
|
|
| def disable_adapters(self) -> None: |
| r""" |
| If you are not familiar with adapters and PEFT methods, we invite you to read more about them on the PEFT |
| official documentation: https://huggingface.co/docs/peft |
| |
| Disable all adapters that are attached to the model. This leads to inferring with the base model only. |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
|
|
| if not self._hf_peft_config_loaded: |
| raise ValueError("No adapter loaded. Please load an adapter first.") |
|
|
| from peft.tuners.tuners_utils import BaseTunerLayer |
|
|
| for _, module in self.named_modules(): |
| if isinstance(module, BaseTunerLayer): |
| module.disable_adapters = True |
|
|
| def enable_adapters(self) -> None: |
| """ |
| If you are not familiar with adapters and PEFT methods, we invite you to read more about them on the PEFT |
| official documentation: https://huggingface.co/docs/peft |
| |
| Enable adapters that are attached to the model. The model will use `self.active_adapter()` |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
|
|
| if not self._hf_peft_config_loaded: |
| raise ValueError("No adapter loaded. Please load an adapter first.") |
|
|
| from peft.tuners.tuners_utils import BaseTunerLayer |
|
|
| for _, module in self.named_modules(): |
| if isinstance(module, BaseTunerLayer): |
| module.disable_adapters = False |
|
|
| def active_adapter(self) -> str: |
| """ |
| If you are not familiar with adapters and PEFT methods, we invite you to read more about them on the PEFT |
| official documentation: https://huggingface.co/docs/peft |
| |
| Gets the current active adapter of the model. |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
|
|
| if not is_peft_available(): |
| raise ImportError("PEFT is not available. Please install PEFT to use this function: `pip install peft`.") |
|
|
| if not self._hf_peft_config_loaded: |
| raise ValueError("No adapter loaded. Please load an adapter first.") |
|
|
| from peft.tuners.tuners_utils import BaseTunerLayer |
|
|
| for _, module in self.named_modules(): |
| if isinstance(module, BaseTunerLayer): |
| return module.active_adapter |
|
|
| def get_adapter_state_dict(self, adapter_name: Optional[str] = None) -> dict: |
| """ |
| If you are not familiar with adapters and PEFT methods, we invite you to read more about them on the PEFT |
| official documentation: https://huggingface.co/docs/peft |
| |
| Gets the adapter state dict that should only contain the weights tensors of the specified adapter_name adapter. |
| If no adapter_name is passed, the active adapter is used. |
| |
| Args: |
| adapter_name (`str`, *optional*): |
| The name of the adapter to get the state dict from. If no name is passed, the active adapter is used. |
| """ |
| check_peft_version(min_version=MIN_PEFT_VERSION) |
|
|
| if not self._hf_peft_config_loaded: |
| raise ValueError("No adapter loaded. Please load an adapter first.") |
|
|
| from peft import get_peft_model_state_dict |
|
|
| if adapter_name is None: |
| adapter_name = self.active_adapter() |
|
|
| adapter_state_dict = get_peft_model_state_dict(self, adapter_name=adapter_name) |
| return adapter_state_dict |
|
|
| def _dispatch_accelerate_model( |
| self, |
| device_map: str, |
| max_memory: Optional[int] = None, |
| offload_folder: Optional[str] = None, |
| offload_index: Optional[int] = None, |
| ) -> None: |
| """ |
| Optional re-dispatch the model and attach new hooks to the model in case the model has been loaded with |
| accelerate (i.e. with `device_map=xxx`) |
| |
| Args: |
| device_map (`str` or `Dict[str, Union[int, str, torch.device]]` or `int` or `torch.device`, *optional*): |
| A map that specifies where each submodule should go. It doesn't need to be refined to each |
| parameter/buffer name, once a given module name is inside, every submodule of it will be sent to the |
| same device. If we only pass the device (*e.g.*, `"cpu"`, `"cuda:1"`, `"mps"`, or a GPU ordinal rank |
| like `1`) on which the model will be allocated, the device map will map the entire model to this |
| device. Passing `device_map = 0` means put the whole model on GPU 0. |
| |
| To have Accelerate compute the most optimized `device_map` automatically, set `device_map="auto"`. For |
| more information about each option see [designing a device |
| map](https://hf.co/docs/accelerate/main/en/usage_guides/big_modeling#designing-a-device-map). |
| max_memory (`Dict`, *optional*): |
| A dictionary device identifier to maximum memory. Will default to the maximum memory available for each |
| GPU and the available CPU RAM if unset. |
| offload_folder (`str` or `os.PathLike`, *optional*): |
| If the `device_map` contains any value `"disk"`, the folder where we will offload weights. |
| offload_index (`int`, *optional*): |
| The offload_index argument to be passed to `accelerate.dispatch_model` method. |
| """ |
| dispatch_model_kwargs = {} |
| |
| |
| if "offload_index" in inspect.signature(dispatch_model).parameters: |
| dispatch_model_kwargs["offload_index"] = offload_index |
|
|
| no_split_module_classes = self._no_split_modules |
|
|
| if device_map != "sequential": |
| max_memory = get_balanced_memory( |
| self, |
| max_memory=max_memory, |
| no_split_module_classes=no_split_module_classes, |
| low_zero=(device_map == "balanced_low_0"), |
| ) |
| if isinstance(device_map, str): |
| device_map = infer_auto_device_map( |
| self, max_memory=max_memory, no_split_module_classes=no_split_module_classes |
| ) |
| dispatch_model( |
| self, |
| device_map=device_map, |
| offload_dir=offload_folder, |
| **dispatch_model_kwargs, |
| ) |
|
|