| | |
| | | name: str, |
| | | retain_dropout: bool = False, |
| | | retain_dropout_modules: Optional[List[str]] = None, |
| | | **kwargs |
| | | **kwargs, |
| | | ): |
| | | if retain_dropout: |
| | | if retain_dropout_modules is not None and self.module_name is None: |
| | |
| | | retain_dropout_modules is None # if None, apply to all modules |
| | | or self.module_name in retain_dropout_modules |
| | | ): |
| | | logging.info( |
| | | "Enabling dropout during inference for module: {}".format(name) |
| | | ) |
| | | logging.info("Enabling dropout during inference for module: {}".format(name)) |
| | | self.apply_during_inference = True |
| | | else: |
| | | logging.info("Disabling dropout for module: {}".format(name)) |
| | |
| | | self.qkv_same_dim = self.kdim == embed_dim and self.vdim == embed_dim |
| | | |
| | | self.num_heads = num_heads |
| | | self.dropout_module = FairseqDropout( |
| | | dropout, module_name=self.__class__.__name__ |
| | | ) |
| | | self.dropout_module = FairseqDropout(dropout, module_name=self.__class__.__name__) |
| | | |
| | | self.head_dim = embed_dim // num_heads |
| | | assert ( |
| | |
| | | start_idx = i * self.head_dim |
| | | end_idx = (i + 1) * self.head_dim |
| | | k_proj_heads_norm.append( |
| | | torch.sum( |
| | | torch.abs( |
| | | self.k_proj.weight[ |
| | | start_idx:end_idx, |
| | | ] |
| | | ) |
| | | ).tolist() |
| | | torch.sum(torch.abs(self.k_proj.weight[start_idx:end_idx,])).tolist() |
| | | + torch.sum(torch.abs(self.k_proj.bias[start_idx:end_idx])).tolist() |
| | | ) |
| | | q_proj_heads_norm.append( |
| | | torch.sum( |
| | | torch.abs( |
| | | self.q_proj.weight[ |
| | | start_idx:end_idx, |
| | | ] |
| | | ) |
| | | ).tolist() |
| | | torch.sum(torch.abs(self.q_proj.weight[start_idx:end_idx,])).tolist() |
| | | + torch.sum(torch.abs(self.q_proj.bias[start_idx:end_idx])).tolist() |
| | | ) |
| | | v_proj_heads_norm.append( |
| | | torch.sum( |
| | | torch.abs( |
| | | self.v_proj.weight[ |
| | | start_idx:end_idx, |
| | | ] |
| | | ) |
| | | ).tolist() |
| | | torch.sum(torch.abs(self.v_proj.weight[start_idx:end_idx,])).tolist() |
| | | + torch.sum(torch.abs(self.v_proj.bias[start_idx:end_idx])).tolist() |
| | | ) |
| | | |
| | | heads_norm = [] |
| | | for i in range(self.num_heads): |
| | | heads_norm.append( |
| | | k_proj_heads_norm[i] + q_proj_heads_norm[i] + v_proj_heads_norm[i] |
| | | ) |
| | | heads_norm.append(k_proj_heads_norm[i] + q_proj_heads_norm[i] + v_proj_heads_norm[i]) |
| | | |
| | | sorted_head_index = sorted( |
| | | range(self.num_heads), key=lambda k: heads_norm[k], reverse=True |
| | | ) |
| | | sorted_head_index = sorted(range(self.num_heads), key=lambda k: heads_norm[k], reverse=True) |
| | | reserve_head_index = [] |
| | | for i in range(num_heads_to_keep): |
| | | start = sorted_head_index[i] * self.head_dim |
| | |
| | | |
| | | for ele in reserve_head_index: |
| | | start_idx, end_idx = ele |
| | | new_q_weight.append( |
| | | self.q_proj.weight[ |
| | | start_idx:end_idx, |
| | | ] |
| | | ) |
| | | new_q_weight.append(self.q_proj.weight[start_idx:end_idx,]) |
| | | new_q_bias.append(self.q_proj.bias[start_idx:end_idx]) |
| | | |
| | | new_k_weight.append( |
| | | self.k_proj.weight[ |
| | | start_idx:end_idx, |
| | | ] |
| | | ) |
| | | new_k_weight.append(self.k_proj.weight[start_idx:end_idx,]) |
| | | |
| | | new_k_bias.append(self.k_proj.bias[start_idx:end_idx]) |
| | | |
| | | new_v_weight.append( |
| | | self.v_proj.weight[ |
| | | start_idx:end_idx, |
| | | ] |
| | | ) |
| | | new_v_weight.append(self.v_proj.weight[start_idx:end_idx,]) |
| | | new_v_bias.append(self.v_proj.bias[start_idx:end_idx]) |
| | | |
| | | new_out_proj_weight.append(self.out_proj.weight[:, start_idx:end_idx]) |
| | |
| | | tgt_len, bsz, embed_dim = query.size() |
| | | src_len = tgt_len |
| | | if not self.skip_embed_dim_check: |
| | | assert ( |
| | | embed_dim == self.embed_dim |
| | | ), f"query dim {embed_dim} != {self.embed_dim}" |
| | | assert embed_dim == self.embed_dim, f"query dim {embed_dim} != {self.embed_dim}" |
| | | assert list(query.size()) == [tgt_len, bsz, embed_dim] |
| | | if key is not None: |
| | | src_len, key_bsz, _ = key.size() |
| | |
| | | k = torch.cat([k, self.bias_k.repeat(1, bsz, 1)]) |
| | | v = torch.cat([v, self.bias_v.repeat(1, bsz, 1)]) |
| | | if attn_mask is not None: |
| | | attn_mask = torch.cat( |
| | | [attn_mask, attn_mask.new_zeros(attn_mask.size(0), 1)], dim=1 |
| | | ) |
| | | attn_mask = torch.cat([attn_mask, attn_mask.new_zeros(attn_mask.size(0), 1)], dim=1) |
| | | if key_padding_mask is not None: |
| | | key_padding_mask = torch.cat( |
| | | [ |
| | |
| | | dim=1, |
| | | ) |
| | | |
| | | q = ( |
| | | q.contiguous() |
| | | .view(tgt_len, bsz * self.num_heads, self.head_dim) |
| | | .transpose(0, 1) |
| | | ) |
| | | q = q.contiguous().view(tgt_len, bsz * self.num_heads, self.head_dim).transpose(0, 1) |
| | | if k is not None: |
| | | k = ( |
| | | k.contiguous() |
| | | .view(-1, bsz * self.num_heads, self.head_dim) |
| | | .transpose(0, 1) |
| | | ) |
| | | k = k.contiguous().view(-1, bsz * self.num_heads, self.head_dim).transpose(0, 1) |
| | | if v is not None: |
| | | v = ( |
| | | v.contiguous() |
| | | .view(-1, bsz * self.num_heads, self.head_dim) |
| | | .transpose(0, 1) |
| | | ) |
| | | v = v.contiguous().view(-1, bsz * self.num_heads, self.head_dim).transpose(0, 1) |
| | | |
| | | if saved_state is not None: |
| | | # saved states are stored with shape (bsz, num_heads, seq_len, head_dim) |
| | |
| | | k = torch.cat([k, k.new_zeros((k.size(0), 1) + k.size()[2:])], dim=1) |
| | | v = torch.cat([v, v.new_zeros((v.size(0), 1) + v.size()[2:])], dim=1) |
| | | if attn_mask is not None: |
| | | attn_mask = torch.cat( |
| | | [attn_mask, attn_mask.new_zeros(attn_mask.size(0), 1)], dim=1 |
| | | ) |
| | | attn_mask = torch.cat([attn_mask, attn_mask.new_zeros(attn_mask.size(0), 1)], dim=1) |
| | | if key_padding_mask is not None: |
| | | key_padding_mask = torch.cat( |
| | | [ |
| | | key_padding_mask, |
| | | torch.zeros(key_padding_mask.size(0), 1).type_as( |
| | | key_padding_mask |
| | | ), |
| | | torch.zeros(key_padding_mask.size(0), 1).type_as(key_padding_mask), |
| | | ], |
| | | dim=1, |
| | | ) |
| | |
| | | attn = self.out_proj(attn) |
| | | attn_weights: Optional[Tensor] = None |
| | | if need_weights: |
| | | attn_weights = attn_weights_float.view( |
| | | bsz, self.num_heads, tgt_len, src_len |
| | | ).transpose(1, 0) |
| | | attn_weights = attn_weights_float.view(bsz, self.num_heads, tgt_len, src_len).transpose( |
| | | 1, 0 |
| | | ) |
| | | if not need_head_weights: |
| | | # average attention weights over heads |
| | | attn_weights = attn_weights.mean(dim=0) |
| | |
| | | (batch_size, src_len - key_padding_mask.size(1)), |
| | | device=key_padding_mask.device, |
| | | ) |
| | | new_key_padding_mask = torch.cat( |
| | | [filler.float(), key_padding_mask.float()], dim=1 |
| | | ) |
| | | new_key_padding_mask = torch.cat([filler.float(), key_padding_mask.float()], dim=1) |
| | | else: |
| | | new_key_padding_mask = key_padding_mask.float() |
| | | else: |
| | |
| | | for k in input_buffer.keys(): |
| | | input_buffer_k = input_buffer[k] |
| | | if input_buffer_k is not None: |
| | | if self.encoder_decoder_attention and input_buffer_k.size( |
| | | if self.encoder_decoder_attention and input_buffer_k.size(0) == new_order.size( |
| | | 0 |
| | | ) == new_order.size(0): |
| | | ): |
| | | break |
| | | input_buffer[k] = input_buffer_k.index_select(0, new_order) |
| | | incremental_state = self._set_input_buffer(incremental_state, input_buffer) |
| | |
| | | if k_bias in state_dict.keys(): |
| | | dim = int(state_dict[k].shape[0] / 3) |
| | | items_to_add[prefix + "q_proj.bias"] = state_dict[k_bias][:dim] |
| | | items_to_add[prefix + "k_proj.bias"] = state_dict[k_bias][ |
| | | dim: 2 * dim |
| | | ] |
| | | items_to_add[prefix + "k_proj.bias"] = state_dict[k_bias][dim : 2 * dim] |
| | | items_to_add[prefix + "v_proj.bias"] = state_dict[k_bias][2 * dim:] |
| | | |
| | | keys_to_remove.append(prefix + "in_proj_bias") |