yezdata commited on
Commit
ab2fce1
·
verified ·
1 Parent(s): 7a5f00a

Delete modeling_emcoder.py

Browse files
Files changed (1) hide show
  1. modeling_emcoder.py +0 -100
modeling_emcoder.py DELETED
@@ -1,100 +0,0 @@
1
- import torch
2
- import torch.nn as nn
3
- from transformers import PreTrainedModel
4
- from .configuration_emcoder import EmCoderConfig
5
-
6
-
7
- class EmCoderCore(nn.Module):
8
- """The core encoder architecture of EmCoder, without the classification head."""
9
- def __init__(self, config: EmCoderConfig):
10
- super().__init__()
11
-
12
- self.token_embedding = nn.Embedding(config.vocab_size, config.d_model)
13
- self.pos_embedding = nn.Embedding(config.max_seq_len, config.d_model)
14
- self.embed_norm = nn.LayerNorm(config.d_model)
15
-
16
- encoder_layer = nn.TransformerEncoderLayer(
17
- d_model=config.d_model,
18
- nhead=config.n_head,
19
- dim_feedforward=config.d_ffn,
20
- dropout=config.dropout,
21
- activation="gelu",
22
- norm_first=True,
23
- batch_first=True
24
- )
25
- self.encoder = nn.TransformerEncoder(
26
- encoder_layer=encoder_layer,
27
- num_layers=config.n_layers
28
- )
29
-
30
- self.final_norm = nn.LayerNorm(config.d_model)
31
- self.dropout = nn.Dropout(config.dropout)
32
-
33
-
34
- def forward(self, x: torch.Tensor, mask: torch.Tensor) -> torch.Tensor:
35
- """Standard forward pass through the encoder."""
36
- seq_len = x.size(1)
37
- pos_ids = torch.arange(seq_len, device=x.device).unsqueeze(0)
38
-
39
- x = self.token_embedding(x) + self.pos_embedding(pos_ids)
40
-
41
- x = self.embed_norm(x)
42
- x = self.dropout(x)
43
-
44
- padding_mask = (mask == 0)
45
-
46
- encoded = self.encoder(x, src_key_padding_mask=padding_mask)
47
- return self.final_norm(encoded)
48
-
49
-
50
- class EmCoder(PreTrainedModel):
51
- """The full EmCoder model, including the classification head."""
52
- config_class = EmCoderConfig
53
-
54
- def __init__(self, config: EmCoderConfig):
55
- super().__init__(config)
56
-
57
- self.encoder = EmCoderCore(config)
58
- self.classifier = nn.Sequential(
59
- nn.Linear(config.d_model, config.d_model),
60
- nn.GELU(),
61
- nn.Dropout(config.dropout),
62
- nn.Linear(config.d_model, config.num_labels)
63
- )
64
-
65
- self.post_init()
66
-
67
- def _set_mc_dropout(self, active: bool = True):
68
- for m in self.modules():
69
- if isinstance(m, nn.Dropout):
70
- m.train(active)
71
-
72
- @staticmethod
73
- def _masked_mean_pooling(features: torch.Tensor, mask: torch.Tensor) -> torch.Tensor:
74
- mask = mask.unsqueeze(-1) # (B, S, 1)
75
- masked_features = features * mask # (B, S, D)
76
- sum_masked_features = masked_features.sum(dim=1) # (B, D)
77
- count_tokens = torch.clamp(mask.sum(dim=1), min=1e-9) # (B, 1)
78
- return sum_masked_features / count_tokens # (B, D)
79
-
80
- def mc_forward(self, x: torch.Tensor, mask: torch.Tensor, n_samples: int) -> torch.Tensor:
81
- """Performs Monte Carlo Dropout inference to quantify epistemic uncertainty."""
82
- self._set_mc_dropout(active=True)
83
-
84
- B, S = x.shape
85
- x_stacked = x.repeat(n_samples, 1) # (n_samples * B, S)
86
- mask_stacked = mask.repeat(n_samples, 1)
87
-
88
- features = self.encoder(x_stacked, mask_stacked)
89
- pooled = self._masked_mean_pooling(features, mask_stacked)
90
- logits = self.classifier(pooled) # (n_samples * B, num_labels)
91
-
92
- return logits.view(n_samples, B, -1)
93
-
94
-
95
- def forward(self, x: torch.Tensor, mask: torch.Tensor) -> torch.Tensor:
96
- """Standard forward pass without MC Dropout."""
97
- features = self.encoder(x, mask)
98
-
99
- pooled = self._masked_mean_pooling(features, mask)
100
- return self.classifier(pooled)