Upload model
Browse files- README.md +199 -0
- config.json +43 -0
- configuration.py +37 -0
- model.safetensors +3 -0
- modeling.py +251 -0
README.md
ADDED
@@ -0,0 +1,199 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
---
|
2 |
+
library_name: transformers
|
3 |
+
tags: []
|
4 |
+
---
|
5 |
+
|
6 |
+
# Model Card for Model ID
|
7 |
+
|
8 |
+
<!-- Provide a quick summary of what the model is/does. -->
|
9 |
+
|
10 |
+
|
11 |
+
|
12 |
+
## Model Details
|
13 |
+
|
14 |
+
### Model Description
|
15 |
+
|
16 |
+
<!-- Provide a longer summary of what this model is. -->
|
17 |
+
|
18 |
+
This is the model card of a 🤗 transformers model that has been pushed on the Hub. This model card has been automatically generated.
|
19 |
+
|
20 |
+
- **Developed by:** [More Information Needed]
|
21 |
+
- **Funded by [optional]:** [More Information Needed]
|
22 |
+
- **Shared by [optional]:** [More Information Needed]
|
23 |
+
- **Model type:** [More Information Needed]
|
24 |
+
- **Language(s) (NLP):** [More Information Needed]
|
25 |
+
- **License:** [More Information Needed]
|
26 |
+
- **Finetuned from model [optional]:** [More Information Needed]
|
27 |
+
|
28 |
+
### Model Sources [optional]
|
29 |
+
|
30 |
+
<!-- Provide the basic links for the model. -->
|
31 |
+
|
32 |
+
- **Repository:** [More Information Needed]
|
33 |
+
- **Paper [optional]:** [More Information Needed]
|
34 |
+
- **Demo [optional]:** [More Information Needed]
|
35 |
+
|
36 |
+
## Uses
|
37 |
+
|
38 |
+
<!-- Address questions around how the model is intended to be used, including the foreseeable users of the model and those affected by the model. -->
|
39 |
+
|
40 |
+
### Direct Use
|
41 |
+
|
42 |
+
<!-- This section is for the model use without fine-tuning or plugging into a larger ecosystem/app. -->
|
43 |
+
|
44 |
+
[More Information Needed]
|
45 |
+
|
46 |
+
### Downstream Use [optional]
|
47 |
+
|
48 |
+
<!-- This section is for the model use when fine-tuned for a task, or when plugged into a larger ecosystem/app -->
|
49 |
+
|
50 |
+
[More Information Needed]
|
51 |
+
|
52 |
+
### Out-of-Scope Use
|
53 |
+
|
54 |
+
<!-- This section addresses misuse, malicious use, and uses that the model will not work well for. -->
|
55 |
+
|
56 |
+
[More Information Needed]
|
57 |
+
|
58 |
+
## Bias, Risks, and Limitations
|
59 |
+
|
60 |
+
<!-- This section is meant to convey both technical and sociotechnical limitations. -->
|
61 |
+
|
62 |
+
[More Information Needed]
|
63 |
+
|
64 |
+
### Recommendations
|
65 |
+
|
66 |
+
<!-- This section is meant to convey recommendations with respect to the bias, risk, and technical limitations. -->
|
67 |
+
|
68 |
+
Users (both direct and downstream) should be made aware of the risks, biases and limitations of the model. More information needed for further recommendations.
|
69 |
+
|
70 |
+
## How to Get Started with the Model
|
71 |
+
|
72 |
+
Use the code below to get started with the model.
|
73 |
+
|
74 |
+
[More Information Needed]
|
75 |
+
|
76 |
+
## Training Details
|
77 |
+
|
78 |
+
### Training Data
|
79 |
+
|
80 |
+
<!-- This should link to a Dataset Card, perhaps with a short stub of information on what the training data is all about as well as documentation related to data pre-processing or additional filtering. -->
|
81 |
+
|
82 |
+
[More Information Needed]
|
83 |
+
|
84 |
+
### Training Procedure
|
85 |
+
|
86 |
+
<!-- This relates heavily to the Technical Specifications. Content here should link to that section when it is relevant to the training procedure. -->
|
87 |
+
|
88 |
+
#### Preprocessing [optional]
|
89 |
+
|
90 |
+
[More Information Needed]
|
91 |
+
|
92 |
+
|
93 |
+
#### Training Hyperparameters
|
94 |
+
|
95 |
+
- **Training regime:** [More Information Needed] <!--fp32, fp16 mixed precision, bf16 mixed precision, bf16 non-mixed precision, fp16 non-mixed precision, fp8 mixed precision -->
|
96 |
+
|
97 |
+
#### Speeds, Sizes, Times [optional]
|
98 |
+
|
99 |
+
<!-- This section provides information about throughput, start/end time, checkpoint size if relevant, etc. -->
|
100 |
+
|
101 |
+
[More Information Needed]
|
102 |
+
|
103 |
+
## Evaluation
|
104 |
+
|
105 |
+
<!-- This section describes the evaluation protocols and provides the results. -->
|
106 |
+
|
107 |
+
### Testing Data, Factors & Metrics
|
108 |
+
|
109 |
+
#### Testing Data
|
110 |
+
|
111 |
+
<!-- This should link to a Dataset Card if possible. -->
|
112 |
+
|
113 |
+
[More Information Needed]
|
114 |
+
|
115 |
+
#### Factors
|
116 |
+
|
117 |
+
<!-- These are the things the evaluation is disaggregating by, e.g., subpopulations or domains. -->
|
118 |
+
|
119 |
+
[More Information Needed]
|
120 |
+
|
121 |
+
#### Metrics
|
122 |
+
|
123 |
+
<!-- These are the evaluation metrics being used, ideally with a description of why. -->
|
124 |
+
|
125 |
+
[More Information Needed]
|
126 |
+
|
127 |
+
### Results
|
128 |
+
|
129 |
+
[More Information Needed]
|
130 |
+
|
131 |
+
#### Summary
|
132 |
+
|
133 |
+
|
134 |
+
|
135 |
+
## Model Examination [optional]
|
136 |
+
|
137 |
+
<!-- Relevant interpretability work for the model goes here -->
|
138 |
+
|
139 |
+
[More Information Needed]
|
140 |
+
|
141 |
+
## Environmental Impact
|
142 |
+
|
143 |
+
<!-- Total emissions (in grams of CO2eq) and additional considerations, such as electricity usage, go here. Edit the suggested text below accordingly -->
|
144 |
+
|
145 |
+
Carbon emissions can be estimated using the [Machine Learning Impact calculator](https://mlco2.github.io/impact#compute) presented in [Lacoste et al. (2019)](https://arxiv.org/abs/1910.09700).
|
146 |
+
|
147 |
+
- **Hardware Type:** [More Information Needed]
|
148 |
+
- **Hours used:** [More Information Needed]
|
149 |
+
- **Cloud Provider:** [More Information Needed]
|
150 |
+
- **Compute Region:** [More Information Needed]
|
151 |
+
- **Carbon Emitted:** [More Information Needed]
|
152 |
+
|
153 |
+
## Technical Specifications [optional]
|
154 |
+
|
155 |
+
### Model Architecture and Objective
|
156 |
+
|
157 |
+
[More Information Needed]
|
158 |
+
|
159 |
+
### Compute Infrastructure
|
160 |
+
|
161 |
+
[More Information Needed]
|
162 |
+
|
163 |
+
#### Hardware
|
164 |
+
|
165 |
+
[More Information Needed]
|
166 |
+
|
167 |
+
#### Software
|
168 |
+
|
169 |
+
[More Information Needed]
|
170 |
+
|
171 |
+
## Citation [optional]
|
172 |
+
|
173 |
+
<!-- If there is a paper or blog post introducing the model, the APA and Bibtex information for that should go in this section. -->
|
174 |
+
|
175 |
+
**BibTeX:**
|
176 |
+
|
177 |
+
[More Information Needed]
|
178 |
+
|
179 |
+
**APA:**
|
180 |
+
|
181 |
+
[More Information Needed]
|
182 |
+
|
183 |
+
## Glossary [optional]
|
184 |
+
|
185 |
+
<!-- If relevant, include terms and calculations in this section that can help readers understand the model or model card. -->
|
186 |
+
|
187 |
+
[More Information Needed]
|
188 |
+
|
189 |
+
## More Information [optional]
|
190 |
+
|
191 |
+
[More Information Needed]
|
192 |
+
|
193 |
+
## Model Card Authors [optional]
|
194 |
+
|
195 |
+
[More Information Needed]
|
196 |
+
|
197 |
+
## Model Card Contact
|
198 |
+
|
199 |
+
[More Information Needed]
|
config.json
ADDED
@@ -0,0 +1,43 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
{
|
2 |
+
"architectures": [
|
3 |
+
"KPRModelForBert"
|
4 |
+
],
|
5 |
+
"attention_probs_dropout_prob": 0.1,
|
6 |
+
"auto_map": {
|
7 |
+
"AutoConfig": "configuration.KPRConfigForBert",
|
8 |
+
"AutoModel": "modeling.KPRModelForBert"
|
9 |
+
},
|
10 |
+
"classifier_dropout": null,
|
11 |
+
"entity_embedding_size": 768,
|
12 |
+
"entity_fusion_activation": "sigmoid",
|
13 |
+
"entity_fusion_method": "multihead_attention",
|
14 |
+
"entity_vocab_size": null,
|
15 |
+
"gradient_checkpointing": false,
|
16 |
+
"hidden_act": "gelu",
|
17 |
+
"hidden_dropout_prob": 0.1,
|
18 |
+
"hidden_size": 768,
|
19 |
+
"id2label": {
|
20 |
+
"0": "LABEL_0"
|
21 |
+
},
|
22 |
+
"initializer_range": 0.02,
|
23 |
+
"intermediate_size": 3072,
|
24 |
+
"label2id": {
|
25 |
+
"LABEL_0": 0
|
26 |
+
},
|
27 |
+
"layer_norm_eps": 1e-12,
|
28 |
+
"max_position_embeddings": 512,
|
29 |
+
"model_type": "kpr-bert",
|
30 |
+
"num_attention_heads": 12,
|
31 |
+
"num_entity_fusion_attention_heads": 1,
|
32 |
+
"num_hidden_layers": 12,
|
33 |
+
"pad_token_id": 0,
|
34 |
+
"position_embedding_type": "absolute",
|
35 |
+
"similarity_function": "cosine",
|
36 |
+
"similarity_temperature": 0.02,
|
37 |
+
"torch_dtype": "float32",
|
38 |
+
"transformers_version": "4.55.2",
|
39 |
+
"type_vocab_size": 2,
|
40 |
+
"use_cache": true,
|
41 |
+
"use_entity_position_embeddings": true,
|
42 |
+
"vocab_size": 30522
|
43 |
+
}
|
configuration.py
ADDED
@@ -0,0 +1,37 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
from transformers.models.bert import BertConfig
|
2 |
+
from transformers.models.xlm_roberta import XLMRobertaConfig
|
3 |
+
|
4 |
+
|
5 |
+
def _init_function(
|
6 |
+
self,
|
7 |
+
entity_vocab_size: int | None = 10000,
|
8 |
+
entity_embedding_size: int = 768,
|
9 |
+
entity_fusion_method: str = "multihead_attention",
|
10 |
+
use_entity_position_embeddings: bool = True,
|
11 |
+
entity_fusion_activation: str = "softmax",
|
12 |
+
num_entity_fusion_attention_heads: int = 12,
|
13 |
+
similarity_function: str = "dot",
|
14 |
+
similarity_temperature: float = 1.0,
|
15 |
+
*args,
|
16 |
+
**kwargs,
|
17 |
+
):
|
18 |
+
self.entity_vocab_size = entity_vocab_size
|
19 |
+
self.entity_embedding_size = entity_embedding_size
|
20 |
+
self.entity_fusion_method = entity_fusion_method
|
21 |
+
self.use_entity_position_embeddings = use_entity_position_embeddings
|
22 |
+
self.entity_fusion_activation = entity_fusion_activation
|
23 |
+
self.num_entity_fusion_attention_heads = num_entity_fusion_attention_heads
|
24 |
+
self.similarity_function = similarity_function
|
25 |
+
self.similarity_temperature = similarity_temperature
|
26 |
+
|
27 |
+
super(self.__class__, self).__init__(*args, **kwargs)
|
28 |
+
|
29 |
+
|
30 |
+
class KPRConfigForBert(BertConfig):
|
31 |
+
__init__ = _init_function
|
32 |
+
model_type = "kpr-bert"
|
33 |
+
|
34 |
+
|
35 |
+
class KPRConfigForXLMRoberta(XLMRobertaConfig):
|
36 |
+
__init__ = _init_function
|
37 |
+
model_type = "kpr-xlm-roberta"
|
model.safetensors
ADDED
@@ -0,0 +1,3 @@
|
|
|
|
|
|
|
|
|
1 |
+
version https://git-lfs.github.com/spec/v1
|
2 |
+
oid sha256:94a371d44cc6e02eb0b65f72235ab0ad0b239ac7ddab67fa36769315439287f9
|
3 |
+
size 448988504
|
modeling.py
ADDED
@@ -0,0 +1,251 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
import math
|
2 |
+
|
3 |
+
import torch
|
4 |
+
import torch.distributed as dist
|
5 |
+
import torch.nn.functional as F
|
6 |
+
from torch import Tensor, nn
|
7 |
+
from transformers import PretrainedConfig
|
8 |
+
from transformers.file_utils import ModelOutput
|
9 |
+
from transformers.models.bert import BertModel, BertPreTrainedModel
|
10 |
+
from transformers.models.xlm_roberta import XLMRobertaModel, XLMRobertaPreTrainedModel
|
11 |
+
|
12 |
+
from .configuration import KPRConfigForBert, KPRConfigForXLMRoberta
|
13 |
+
|
14 |
+
|
15 |
+
class EntityEmbeddings(nn.Module):
|
16 |
+
def __init__(self, config: PretrainedConfig):
|
17 |
+
super().__init__()
|
18 |
+
self.config = config
|
19 |
+
|
20 |
+
if config.entity_vocab_size is not None:
|
21 |
+
self.embeddings = nn.Embedding(config.entity_vocab_size, config.entity_embedding_size, padding_idx=0)
|
22 |
+
self.embeddings.weight.requires_grad = False
|
23 |
+
|
24 |
+
# The 0-th position corresponds to the [CLS] token which does not correspond to any entity
|
25 |
+
self.position_embeddings = nn.Embedding(config.max_position_embeddings, config.hidden_size, padding_idx=0)
|
26 |
+
|
27 |
+
self.dense = nn.Linear(config.entity_embedding_size, config.hidden_size, bias=False)
|
28 |
+
self.LayerNorm = nn.LayerNorm(config.hidden_size, eps=config.layer_norm_eps)
|
29 |
+
self.dropout = nn.Dropout(config.hidden_dropout_prob)
|
30 |
+
|
31 |
+
def forward(self, entity_ids: Tensor | None, entity_embeds: Tensor | None, entity_position_ids: Tensor) -> Tensor:
|
32 |
+
if entity_embeds is not None:
|
33 |
+
entity_embeddings = entity_embeds
|
34 |
+
elif entity_ids is not None:
|
35 |
+
if self.config.entity_vocab_size is None:
|
36 |
+
raise ValueError("Entity embeddings are not constructed because entity_vocab_size is None.")
|
37 |
+
entity_embeddings = self.embeddings(entity_ids)
|
38 |
+
else:
|
39 |
+
raise ValueError("Either entity_ids or entity_embeds need to be provided.")
|
40 |
+
|
41 |
+
entity_embeddings = self.dense(entity_embeddings)
|
42 |
+
|
43 |
+
if self.config.use_entity_position_embeddings:
|
44 |
+
entity_position_embeddings = self.position_embeddings(
|
45 |
+
entity_position_ids
|
46 |
+
) # batch, entities, positions, hidden
|
47 |
+
entity_position_embeddings = torch.sum(entity_position_embeddings, dim=2)
|
48 |
+
entity_position_embeddings = entity_position_embeddings / entity_position_ids.ne(0).sum(dim=2).clamp(
|
49 |
+
min=1
|
50 |
+
).unsqueeze(-1)
|
51 |
+
entity_embeddings = entity_embeddings + entity_position_embeddings
|
52 |
+
|
53 |
+
entity_embeddings = self.LayerNorm(entity_embeddings)
|
54 |
+
entity_embeddings = self.dropout(entity_embeddings)
|
55 |
+
|
56 |
+
return entity_embeddings
|
57 |
+
|
58 |
+
|
59 |
+
class EntityFusionMultiHeadAttention(nn.Module):
|
60 |
+
def __init__(self, config: PretrainedConfig):
|
61 |
+
super().__init__()
|
62 |
+
self.config = config
|
63 |
+
|
64 |
+
self.num_attention_heads = config.num_entity_fusion_attention_heads
|
65 |
+
self.attention_head_size = int(config.hidden_size / self.num_attention_heads)
|
66 |
+
|
67 |
+
self.query = nn.Linear(config.hidden_size, config.hidden_size)
|
68 |
+
self.key = nn.Linear(config.hidden_size, config.hidden_size)
|
69 |
+
self.value = nn.Linear(config.hidden_size, config.hidden_size)
|
70 |
+
|
71 |
+
def transpose_for_scores(self, x: torch.Tensor) -> torch.Tensor:
|
72 |
+
new_x_shape = x.size()[:-1] + (self.num_attention_heads, self.attention_head_size)
|
73 |
+
x = x.view(new_x_shape)
|
74 |
+
return x.permute(0, 2, 1, 3)
|
75 |
+
|
76 |
+
def forward(
|
77 |
+
self, query: torch.Tensor, key: torch.Tensor, value: torch.Tensor, key_padding_mask: torch.Tensor
|
78 |
+
) -> tuple[torch.Tensor, torch.Tensor]:
|
79 |
+
query_layer = self.transpose_for_scores(self.query(query))
|
80 |
+
key_layer = self.transpose_for_scores(self.key(key))
|
81 |
+
value_layer = self.transpose_for_scores(self.value(value))
|
82 |
+
|
83 |
+
attention_scores = torch.matmul(query_layer, key_layer.transpose(-1, -2))
|
84 |
+
attention_scores = attention_scores / math.sqrt(self.attention_head_size)
|
85 |
+
|
86 |
+
dtype = attention_scores.dtype
|
87 |
+
key_padding_mask_scores = key_padding_mask[:, None, None, :]
|
88 |
+
key_padding_mask_scores = key_padding_mask_scores.to(dtype=dtype)
|
89 |
+
key_padding_mask_scores = key_padding_mask_scores * torch.finfo(dtype).min
|
90 |
+
attention_scores = attention_scores + key_padding_mask_scores
|
91 |
+
orig_attention_scores = attention_scores.clone()
|
92 |
+
|
93 |
+
if self.config.entity_fusion_activation == "sigmoid":
|
94 |
+
# https://arxiv.org/abs/2409.04431
|
95 |
+
entity_fusion_sigmoid_bias = key_padding_mask.eq(0).sum(dim=-1, keepdim=True)[:, :, None, None]
|
96 |
+
entity_fusion_sigmoid_bias = entity_fusion_sigmoid_bias.to(dtype)
|
97 |
+
entity_fusion_sigmoid_bias = -torch.log(entity_fusion_sigmoid_bias)
|
98 |
+
|
99 |
+
attention_scores = attention_scores + entity_fusion_sigmoid_bias
|
100 |
+
normalized_attention_scores = torch.sigmoid(attention_scores)
|
101 |
+
else:
|
102 |
+
normalized_attention_scores = nn.functional.softmax(attention_scores, dim=-1)
|
103 |
+
|
104 |
+
context_layer = torch.matmul(normalized_attention_scores, value_layer)
|
105 |
+
|
106 |
+
context_layer = context_layer.permute(0, 2, 1, 3).contiguous()
|
107 |
+
new_context_layer_shape = context_layer.size()[:-2] + (self.config.hidden_size,)
|
108 |
+
context_layer = context_layer.view(new_context_layer_shape)
|
109 |
+
|
110 |
+
return (context_layer, orig_attention_scores)
|
111 |
+
|
112 |
+
|
113 |
+
class EntityFusionLayer(nn.Module):
|
114 |
+
def __init__(self, config: PretrainedConfig):
|
115 |
+
super().__init__()
|
116 |
+
self.config = config
|
117 |
+
|
118 |
+
self.entity_embeddings = EntityEmbeddings(config)
|
119 |
+
self.entity_fusion_layer = EntityFusionMultiHeadAttention(config)
|
120 |
+
self.dropout = nn.Dropout(config.hidden_dropout_prob)
|
121 |
+
self.LayerNorm = nn.LayerNorm(config.hidden_size, eps=config.layer_norm_eps)
|
122 |
+
|
123 |
+
self.noop_embeddings = nn.Parameter(torch.zeros(1, 1, config.hidden_size))
|
124 |
+
|
125 |
+
def forward(
|
126 |
+
self,
|
127 |
+
entity_ids: Tensor | None,
|
128 |
+
entity_embeds: Tensor | None,
|
129 |
+
entity_position_ids: Tensor,
|
130 |
+
cls_embeddings: Tensor,
|
131 |
+
) -> tuple[torch.Tensor, torch.Tensor]:
|
132 |
+
entity_embeddings = self.entity_embeddings(entity_ids, entity_embeds, entity_position_ids)
|
133 |
+
|
134 |
+
batch_size = entity_ids.size(0)
|
135 |
+
kv_embeddings = entity_embeddings
|
136 |
+
key_padding_mask = entity_ids.eq(0)
|
137 |
+
cls_embeddings = cls_embeddings.unsqueeze(1)
|
138 |
+
|
139 |
+
noop_embeddings = self.noop_embeddings.expand(batch_size, 1, -1)
|
140 |
+
|
141 |
+
kv_embeddings = torch.cat([noop_embeddings, kv_embeddings], dim=1)
|
142 |
+
noop_padding_mask = torch.zeros(batch_size, 1, device=entity_ids.device, dtype=torch.bool)
|
143 |
+
key_padding_mask = torch.cat([noop_padding_mask, key_padding_mask], dim=1)
|
144 |
+
|
145 |
+
entity_embeddings, attention_scores = self.entity_fusion_layer(
|
146 |
+
cls_embeddings, kv_embeddings, kv_embeddings, key_padding_mask=key_padding_mask
|
147 |
+
)
|
148 |
+
entity_embeddings = self.dropout(entity_embeddings)
|
149 |
+
output_embeddings = entity_embeddings + cls_embeddings
|
150 |
+
output_embeddings = self.LayerNorm(output_embeddings)
|
151 |
+
|
152 |
+
output_embeddings = output_embeddings.squeeze(1)
|
153 |
+
|
154 |
+
return output_embeddings, attention_scores
|
155 |
+
|
156 |
+
|
157 |
+
class KPRMixin:
|
158 |
+
def _forward(self, **inputs: dict[str, Tensor]) -> tuple[Tensor] | tuple[Tensor, Tensor] | ModelOutput:
|
159 |
+
return_dict = inputs.pop("return_dict", True)
|
160 |
+
|
161 |
+
if self.training:
|
162 |
+
query_embeddings = self.encode(**inputs["queries"])
|
163 |
+
passage_embeddings = self.encode(**inputs["passages"])
|
164 |
+
|
165 |
+
query_embeddings = self._dist_gather_tensor(query_embeddings)
|
166 |
+
passage_embeddings = self._dist_gather_tensor(passage_embeddings)
|
167 |
+
|
168 |
+
scores = self._compute_similarity(query_embeddings, passage_embeddings)
|
169 |
+
scores = scores / self.config.similarity_temperature
|
170 |
+
scores = scores.view(query_embeddings.size(0), -1)
|
171 |
+
|
172 |
+
ce_target = torch.arange(scores.size(0), device=scores.device, dtype=torch.long)
|
173 |
+
ce_target = ce_target * (passage_embeddings.size(0) // query_embeddings.size(0))
|
174 |
+
loss = torch.nn.CrossEntropyLoss(reduction="mean")(scores, ce_target)
|
175 |
+
|
176 |
+
if return_dict:
|
177 |
+
return ModelOutput(loss=loss, scores=scores)
|
178 |
+
else:
|
179 |
+
return (loss, scores)
|
180 |
+
|
181 |
+
else:
|
182 |
+
sentence_embeddings = self.encode(**inputs).unsqueeze(1)
|
183 |
+
if return_dict:
|
184 |
+
return ModelOutput(sentence_embeddings=sentence_embeddings)
|
185 |
+
else:
|
186 |
+
return (sentence_embeddings,)
|
187 |
+
|
188 |
+
def encode(self, **inputs: dict[str, Tensor]) -> Tensor:
|
189 |
+
entity_ids = inputs.pop("entity_ids", None)
|
190 |
+
entity_position_ids = inputs.pop("entity_position_ids", None)
|
191 |
+
entity_embeds = inputs.pop("entity_embeds", None)
|
192 |
+
|
193 |
+
outputs = getattr(self, self.base_model_prefix)(**inputs)
|
194 |
+
output_embeddings = outputs.last_hidden_state[:, 0]
|
195 |
+
|
196 |
+
if self.config.entity_fusion_method != "none":
|
197 |
+
output_embeddings, _ = self.entity_fusion_layer(
|
198 |
+
entity_ids=entity_ids,
|
199 |
+
entity_embeds=entity_embeds,
|
200 |
+
entity_position_ids=entity_position_ids,
|
201 |
+
cls_embeddings=output_embeddings,
|
202 |
+
)
|
203 |
+
if self.config.similarity_function == "cosine":
|
204 |
+
output_embeddings = F.normalize(output_embeddings, p=2, dim=-1)
|
205 |
+
|
206 |
+
return output_embeddings
|
207 |
+
|
208 |
+
def _dist_gather_tensor(self, t: torch.Tensor) -> torch.Tensor:
|
209 |
+
t = t.contiguous()
|
210 |
+
tensor_list = [torch.empty_like(t) for _ in range(dist.get_world_size())]
|
211 |
+
dist.all_gather(tensor_list, t)
|
212 |
+
|
213 |
+
tensor_list[dist.get_rank()] = t
|
214 |
+
gathered_tensor = torch.cat(tensor_list, dim=0)
|
215 |
+
|
216 |
+
return gathered_tensor
|
217 |
+
|
218 |
+
def _compute_similarity(self, query_embeddings: Tensor, passage_embeddings: Tensor) -> Tensor:
|
219 |
+
return torch.matmul(query_embeddings, passage_embeddings.transpose(-2, -1))
|
220 |
+
|
221 |
+
|
222 |
+
class KPRModelForBert(BertPreTrainedModel, KPRMixin):
|
223 |
+
config_class = KPRConfigForBert
|
224 |
+
|
225 |
+
def __init__(self, config: KPRConfigForBert):
|
226 |
+
BertPreTrainedModel.__init__(self, config)
|
227 |
+
|
228 |
+
self.bert = BertModel(config)
|
229 |
+
if self.config.entity_fusion_method != "none":
|
230 |
+
self.entity_fusion_layer = EntityFusionLayer(config)
|
231 |
+
|
232 |
+
self.post_init()
|
233 |
+
|
234 |
+
def forward(self, *args, **kwargs):
|
235 |
+
return self._forward(*args, **kwargs)
|
236 |
+
|
237 |
+
|
238 |
+
class KPRModelForXLMRoberta(XLMRobertaPreTrainedModel, KPRMixin):
|
239 |
+
config_class = KPRConfigForXLMRoberta
|
240 |
+
|
241 |
+
def __init__(self, config: KPRConfigForXLMRoberta):
|
242 |
+
XLMRobertaPreTrainedModel.__init__(self, config)
|
243 |
+
|
244 |
+
self.roberta = XLMRobertaModel(config)
|
245 |
+
if self.config.entity_fusion_method != "none":
|
246 |
+
self.entity_fusion_layer = EntityFusionLayer(config)
|
247 |
+
|
248 |
+
self.post_init()
|
249 |
+
|
250 |
+
def forward(self, *args, **kwargs):
|
251 |
+
return self._forward(*args, **kwargs)
|