File size: 1,811 Bytes
d73500e | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | import logging
logger = logging.getLogger(__name__)
"""For recording weights"""
class HiddenStatesRecordWrapper:
def __init__(self, layer, layer_name="none", record_input=True, record_output=True):
self.layer = layer
self.layer_name = layer_name
self.record_input = record_input
self.record_output = record_output
if record_input:
self.input_hidden_states = []
if record_output:
self.output_hidden_states = []
def record(self, input, output):
# input: (1, seq_len, hidden_size)
if self.record_input:
self.input_hidden_states.append(input.squeeze(0).clone().cpu())
if self.record_output:
self.output_hidden_states.append(output.squeeze(0).clone().cpu())
"""
# Extended Wrapper to include attention recording
class HiddenStatesRecordWrapper:
def __init__(self, layer, layer_name="none", record_input=True, record_output=True, record_attention=True):
self.layer = layer
self.layer_name = layer_name
self.record_input = record_input
self.record_output = record_output
self.record_attention = record_attention
if self.record_input:
self.input_hidden_states = []
if self.record_output:
self.output_hidden_states = []
if self.record_attention:
self.attention_scores = []
def record(self, input, output, attention=None):
if self.record_input:
self.input_hidden_states.append(input.squeeze(0).clone().cpu())
if self.record_output:
self.output_hidden_states.append(output.squeeze(0).clone().cpu())
if self.record_attention and attention is not None:
self.attention_scores.append(attention.clone().cpu())
""" |