modeling_tf_gpt2.py 29.8 KB
Newer Older
thomwolf's avatar
WIP  
thomwolf committed
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
# coding=utf-8
# Copyright 2018 The OpenAI Team Authors and HuggingFace Inc. team.
# Copyright (c) 2018, NVIDIA CORPORATION.  All rights reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
""" TF 2.0 OpenAI GPT-2 model. """

from __future__ import absolute_import, division, print_function, unicode_literals

import collections
import json
import logging
import math
import os
import sys
from io import open

import numpy as np
import tensorflow as tf

thomwolf's avatar
thomwolf committed
31
32
from .modeling_tf_utils import (TFPreTrainedModel, TFConv1D, TFSharedEmbeddings,
                                TFSequenceSummary, shape_list)
thomwolf's avatar
WIP  
thomwolf committed
33
34
from .configuration_gpt2 import GPT2Config
from .file_utils import add_start_docstrings
35
from .modeling_tf_pytorch_utils import load_pytorch_checkpoint_in_tf2_model
thomwolf's avatar
WIP  
thomwolf committed
36
37
38

logger = logging.getLogger(__name__)

thomwolf's avatar
thomwolf committed
39
TF_GPT2_PRETRAINED_MODEL_ARCHIVE_MAP = {"gpt2": "https://s3.amazonaws.com/models.huggingface.co/bert/gpt2-tf_model.h5",
thomwolf's avatar
WIP  
thomwolf committed
40
41
42
43
                                     "gpt2-medium": "https://s3.amazonaws.com/models.huggingface.co/bert/gpt2-medium-tf_model.h5",
                                     "gpt2-large": "https://s3.amazonaws.com/models.huggingface.co/bert/gpt2-large-tf_model.h5"}


44
45
def load_gpt2_pt_weights_in_tf2(tf_model, pytorch_checkpoint_path):
    # build the network
thomwolf's avatar
WIP  
thomwolf committed
46
47
    inputs_list = [[7, 6, 0, 0, 1], [1, 2, 3, 0, 0], [0, 0, 0, 4, 5]]
    tf_inputs = tf.constant(inputs_list)
48
    tfo = tf_model(tf_inputs, training=False)
49
    return load_pytorch_checkpoint_in_tf2_model(tf_model, pytorch_checkpoint_path, tf_inputs=tf_inputs)
thomwolf's avatar
WIP  
thomwolf committed
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66


def gelu(x):
    """Gaussian Error Linear Unit.
    This is a smoother version of the RELU.
    Original paper: https://arxiv.org/abs/1606.08415
    Args:
        x: float Tensor to perform activation.
    Returns:
        `x` with the GELU activation applied.
    """
    cdf = 0.5 * (1.0 + tf.tanh(
        (np.sqrt(2 / np.pi) * (x + 0.044715 * tf.pow(x, 3)))))
    return x * cdf


class TFAttention(tf.keras.layers.Layer):
thomwolf's avatar
thomwolf committed
67
68
    def __init__(self, nx, n_ctx, config, scale=False, **kwargs):
        super(TFAttention, self).__init__(**kwargs)
thomwolf's avatar
WIP  
thomwolf committed
69
70
71
72
73
        self.output_attentions = config.output_attentions

        n_state = nx  # in Attention: n_state=768 (nx=n_embd)
        # [switch nx => n_state from Block to Attention to keep identical to TF implem]
        assert n_state % config.n_head == 0
thomwolf's avatar
thomwolf committed
74
        self.n_ctx = n_ctx
thomwolf's avatar
WIP  
thomwolf committed
75
76
77
78
        self.n_head = config.n_head
        self.split_size = n_state
        self.scale = scale

thomwolf's avatar
thomwolf committed
79
80
        self.c_attn = TFConv1D(n_state * 3, nx, name='c_attn')
        self.c_proj = TFConv1D(n_state, nx, name='c_proj')
thomwolf's avatar
thomwolf committed
81
82
        self.attn_dropout = tf.keras.layers.Dropout(config.attn_pdrop)
        self.resid_dropout = tf.keras.layers.Dropout(config.resid_pdrop)
thomwolf's avatar
WIP  
thomwolf committed
83
84
85
        self.pruned_heads = set()

    def prune_heads(self, heads):
thomwolf's avatar
thomwolf committed
86
87
88
        pass

    @staticmethod
thomwolf's avatar
thomwolf committed
89
    def causal_attention_mask(nd, ns, dtype):
thomwolf's avatar
thomwolf committed
90
91
92
93
94
95
96
97
98
        """1's in the lower triangle, counting from the lower right corner.
        Same as tf.matrix_band_part(tf.ones([nd, ns]), -1, ns-nd), but doesn't produce garbage on TPUs.
        """
        i = tf.range(nd)[:,None]
        j = tf.range(ns)
        m = i >= j - ns + nd
        return tf.cast(m, dtype)

    def _attn(self, inputs, training=False):
thomwolf's avatar
thomwolf committed
99
        q, k, v, attention_mask, head_mask = inputs
thomwolf's avatar
thomwolf committed
100
101
        # q, k, v have shape [batch, heads, sequence, features]
        w = tf.matmul(q, k, transpose_b=True)
thomwolf's avatar
WIP  
thomwolf committed
102
        if self.scale:
thomwolf's avatar
thomwolf committed
103
104
            dk = tf.cast(tf.shape(k)[-1], tf.float32) # scale attention_scores
            w = w / tf.math.sqrt(dk)
thomwolf's avatar
thomwolf committed
105
106
107

        # w has shape [batch, heads, dst_sequence, src_sequence], where information flows from src to dst.
        _, _, nd, ns = shape_list(w)
thomwolf's avatar
thomwolf committed
108
        b = self.causal_attention_mask(nd, ns, dtype=w.dtype)
thomwolf's avatar
thomwolf committed
109
        b = tf.reshape(b, [1, 1, nd, ns])
thomwolf's avatar
WIP  
thomwolf committed
110
111
        w = w * b - 1e4 * (1 - b)

thomwolf's avatar
thomwolf committed
112
113
114
115
116
        if attention_mask is not None:
            # Apply the attention mask
            w = w + attention_mask

        w = tf.nn.softmax(w, axis=-1)
thomwolf's avatar
thomwolf committed
117
        w = self.attn_dropout(w, training=training)
thomwolf's avatar
WIP  
thomwolf committed
118
119
120
121
122

        # Mask heads if we want to
        if head_mask is not None:
            w = w * head_mask

thomwolf's avatar
thomwolf committed
123
        outputs = [tf.matmul(w, v)]
thomwolf's avatar
WIP  
thomwolf committed
124
125
126
127
128
        if self.output_attentions:
            outputs.append(w)
        return outputs

    def merge_heads(self, x):
thomwolf's avatar
thomwolf committed
129
        x = tf.transpose(x, [0, 2, 1, 3])
thomwolf's avatar
thomwolf committed
130
131
        x_shape = shape_list(x)
        new_x_shape = x_shape[:-2] + [x_shape[-2] * x_shape[-1]]
thomwolf's avatar
thomwolf committed
132
133
134
        return tf.reshape(x, new_x_shape)

    def split_heads(self, x):
thomwolf's avatar
thomwolf committed
135
136
        x_shape = shape_list(x)
        new_x_shape = x_shape[:-1] + [self.n_head, x_shape[-1] // self.n_head]
thomwolf's avatar
thomwolf committed
137
138
139
140
        x = tf.reshape(x, new_x_shape)
        return tf.transpose(x, (0, 2, 1, 3))  # (batch, head, seq_length, head_features)

    def call(self, inputs, training=False):
thomwolf's avatar
thomwolf committed
141
        x, layer_past, attention_mask, head_mask = inputs
thomwolf's avatar
WIP  
thomwolf committed
142
143

        x = self.c_attn(x)
thomwolf's avatar
thomwolf committed
144
        query, key, value = tf.split(x, 3, axis=2)
thomwolf's avatar
WIP  
thomwolf committed
145
        query = self.split_heads(query)
thomwolf's avatar
thomwolf committed
146
        key = self.split_heads(key)
thomwolf's avatar
WIP  
thomwolf committed
147
148
        value = self.split_heads(value)
        if layer_past is not None:
thomwolf's avatar
thomwolf committed
149
150
151
152
            past_key, past_value = tf.unstack(layer_past, axis=1)
            key = tf.concat([past_key, key], axis=-2)
            value = tf.concat([past_value, value], axis=-2)
        present = tf.stack([key, value], axis=1)
thomwolf's avatar
WIP  
thomwolf committed
153

thomwolf's avatar
thomwolf committed
154
        attn_outputs = self._attn([query, key, value, attention_mask, head_mask], training=training)
thomwolf's avatar
WIP  
thomwolf committed
155
156
157
158
        a = attn_outputs[0]

        a = self.merge_heads(a)
        a = self.c_proj(a)
thomwolf's avatar
thomwolf committed
159
        a = self.resid_dropout(a, training=training)
thomwolf's avatar
WIP  
thomwolf committed
160
161
162
163
164

        outputs = [a, present] + attn_outputs[1:]
        return outputs  # a, present, (attentions)


thomwolf's avatar
thomwolf committed
165
class TFMLP(tf.keras.layers.Layer):
thomwolf's avatar
thomwolf committed
166
167
    def __init__(self, n_state, config, **kwargs):
        super(TFMLP, self).__init__(**kwargs)
thomwolf's avatar
WIP  
thomwolf committed
168
        nx = config.n_embd
thomwolf's avatar
thomwolf committed
169
170
        self.c_fc = TFConv1D(n_state, nx, name='c_fc')
        self.c_proj = TFConv1D(nx, n_state, name='c_proj')
thomwolf's avatar
WIP  
thomwolf committed
171
        self.act = gelu
thomwolf's avatar
thomwolf committed
172
        self.dropout = tf.keras.layers.Dropout(config.resid_pdrop)
thomwolf's avatar
WIP  
thomwolf committed
173

thomwolf's avatar
thomwolf committed
174
    def call(self, x, training=False):
thomwolf's avatar
WIP  
thomwolf committed
175
176
        h = self.act(self.c_fc(x))
        h2 = self.c_proj(h)
thomwolf's avatar
thomwolf committed
177
        h2 = self.dropout(h2, training=training)
thomwolf's avatar
thomwolf committed
178
        return h2
thomwolf's avatar
WIP  
thomwolf committed
179
180


thomwolf's avatar
thomwolf committed
181
182
183
class TFBlock(tf.keras.layers.Layer):
    def __init__(self, n_ctx, config, scale=False, **kwargs):
        super(TFBlock, self).__init__(**kwargs)
thomwolf's avatar
WIP  
thomwolf committed
184
        nx = config.n_embd
thomwolf's avatar
thomwolf committed
185
186
187
188
        self.ln_1 = tf.keras.layers.LayerNormalization(epsilon=config.layer_norm_epsilon, name='ln_1')
        self.attn = TFAttention(nx, n_ctx, config, scale, name='attn')
        self.ln_2 = tf.keras.layers.LayerNormalization(epsilon=config.layer_norm_epsilon, name='ln_2')
        self.mlp = TFMLP(4 * nx, config, name='mlp')
thomwolf's avatar
WIP  
thomwolf committed
189

thomwolf's avatar
thomwolf committed
190
191
    def call(self, inputs, training=False):
        x, layer_past, attention_mask, head_mask = inputs
thomwolf's avatar
WIP  
thomwolf committed
192

thomwolf's avatar
thomwolf committed
193
194
195
        a = self.ln_1(x)
        output_attn = self.attn([a, layer_past, attention_mask, head_mask], training=training)
        a = output_attn[0]  # output_attn: a, present, (attentions)
thomwolf's avatar
WIP  
thomwolf committed
196
        x = x + a
thomwolf's avatar
thomwolf committed
197
198
199

        m = self.ln_2(x)
        m = self.mlp(m, training=training)
thomwolf's avatar
WIP  
thomwolf committed
200
201
202
203
204
        x = x + m

        outputs = [x] + output_attn[1:]
        return outputs  # x, present, (attentions)

thomwolf's avatar
thomwolf committed
205
206
207
208
209
210

class TFGPT2MainLayer(tf.keras.layers.Layer):
    def __init__(self, config, *inputs, **kwargs):
        super(TFGPT2MainLayer, self).__init__(config, *inputs, **kwargs)
        self.output_hidden_states = config.output_hidden_states
        self.output_attentions = config.output_attentions
thomwolf's avatar
thomwolf committed
211
        self.num_hidden_layers = config.n_layer
thomwolf's avatar
thomwolf committed
212
213
214
        self.vocab_size = config.vocab_size
        self.n_embd = config.n_embd

thomwolf's avatar
thomwolf committed
215
        self.wte = TFSharedEmbeddings(config.vocab_size, config.hidden_size, name='wte')
thomwolf's avatar
thomwolf committed
216
217
        self.wpe = tf.keras.layers.Embedding(config.n_positions, config.n_embd, name='wpe')
        self.drop = tf.keras.layers.Dropout(config.embd_pdrop)
thomwolf's avatar
thomwolf committed
218
219
220
        self.h = [TFBlock(config.n_ctx,
                          config,
                          scale=True,
221
                          name='h_._{}'.format(i)) for i in range(config.n_layer)]
thomwolf's avatar
thomwolf committed
222
223
224
225
226
227
228
229
230
231
232
        self.ln_f = tf.keras.layers.LayerNormalization(epsilon=config.layer_norm_epsilon, name='ln_f')

    def _resize_token_embeddings(self, new_num_tokens):
        raise NotImplementedError

    def _prune_heads(self, heads_to_prune):
        """ Prunes heads of the model.
            heads_to_prune: dict of {layer_num: list of heads to prune in this layer}
        """
        raise NotImplementedError

thomwolf's avatar
thomwolf committed
233
234
    def call(self, inputs, past=None, attention_mask=None, token_type_ids=None, position_ids=None, head_mask=None, training=False):
        if isinstance(inputs, (tuple, list)):
thomwolf's avatar
thomwolf committed
235
            input_ids = inputs[0]
thomwolf's avatar
thomwolf committed
236
237
238
239
240
            past = inputs[1] if len(inputs) > 1 else past
            attention_mask = inputs[2] if len(inputs) > 2 else attention_mask
            token_type_ids = inputs[3] if len(inputs) > 3 else token_type_ids
            position_ids = inputs[4] if len(inputs) > 4 else position_ids
            head_mask = inputs[5] if len(inputs) > 5 else head_mask
thomwolf's avatar
thomwolf committed
241
            assert len(inputs) <= 6, "Too many inputs."
thomwolf's avatar
thomwolf committed
242
        elif isinstance(inputs, dict):
thomwolf's avatar
thomwolf committed
243
            input_ids = inputs.get('input_ids')
thomwolf's avatar
thomwolf committed
244
245
246
247
248
            past = inputs.get('past', past)
            attention_mask = inputs.get('attention_mask', attention_mask)
            token_type_ids = inputs.get('token_type_ids', token_type_ids)
            position_ids = inputs.get('position_ids', position_ids)
            head_mask = inputs.get('head_mask', head_mask)
thomwolf's avatar
thomwolf committed
249
            assert len(inputs) <= 6, "Too many inputs."
thomwolf's avatar
thomwolf committed
250
251
        else:
            input_ids = inputs
thomwolf's avatar
thomwolf committed
252
253
254
255
256

        if past is None:
            past_length = 0
            past = [None] * len(self.h)
        else:
thomwolf's avatar
thomwolf committed
257
            past_length = shape_list(past[0][0])[-2]
thomwolf's avatar
thomwolf committed
258
        if position_ids is None:
thomwolf's avatar
thomwolf committed
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
            position_ids = tf.range(past_length, shape_list(input_ids)[-1] + past_length, dtype=tf.int32)[tf.newaxis, :]

        if attention_mask is not None:
            # We create a 3D attention mask from a 2D tensor mask.
            # Sizes are [batch_size, 1, 1, to_seq_length]
            # So we can broadcast to [batch_size, num_heads, from_seq_length, to_seq_length]
            # this attention mask is more simple than the triangular masking of causal attention
            # used in OpenAI GPT, we just need to prepare the broadcast dimension here.
            attention_mask = attention_mask[:, tf.newaxis, tf.newaxis, :]

            # Since attention_mask is 1.0 for positions we want to attend and 0.0 for
            # masked positions, this operation will create a tensor which is 0.0 for
            # positions we want to attend and -10000.0 for masked positions.
            # Since we are adding it to the raw scores before the softmax, this is
            # effectively the same as removing these entirely.

            attention_mask = tf.cast(attention_mask, tf.float32)
            attention_mask = (1.0 - attention_mask) * -10000.0
        else:
            attention_mask = None
thomwolf's avatar
thomwolf committed
279
280
281
282

        # Prepare head mask if needed
        # 1.0 in head_mask indicate we keep the head
        # attention_probs has shape bsz x n_heads x N x N
thomwolf's avatar
thomwolf committed
283
284
285
286
        # input head_mask has shape [num_heads] or [num_hidden_layers x num_heads]
        # and head_mask is converted to shape [num_hidden_layers x batch x num_heads x seq_length x seq_length]
        if not head_mask is None:
            raise NotImplementedError
thomwolf's avatar
thomwolf committed
287
        else:
thomwolf's avatar
thomwolf committed
288
289
            head_mask = [None] * self.num_hidden_layers
            # head_mask = tf.constant([0] * self.num_hidden_layers)
thomwolf's avatar
thomwolf committed
290

thomwolf's avatar
thomwolf committed
291
292
293
        input_shape = shape_list(input_ids)
        input_ids = tf.reshape(input_ids, [-1, input_shape[-1]])
        position_ids = tf.reshape(position_ids, [-1, shape_list(position_ids)[-1]])
thomwolf's avatar
thomwolf committed
294

thomwolf's avatar
thomwolf committed
295
        inputs_embeds = self.wte(input_ids, mode='embedding')
thomwolf's avatar
thomwolf committed
296
297
        position_embeds = self.wpe(position_ids)
        if token_type_ids is not None:
thomwolf's avatar
thomwolf committed
298
299
            token_type_ids = tf.reshape(token_type_ids, [-1, shape_list(token_type_ids)[-1]])
            token_type_embeds = self.wte(token_type_ids, mode='embedding')
thomwolf's avatar
thomwolf committed
300
301
302
        else:
            token_type_embeds = 0
        hidden_states = inputs_embeds + position_embeds + token_type_embeds
thomwolf's avatar
thomwolf committed
303
        hidden_states = self.drop(hidden_states, training=training)
thomwolf's avatar
thomwolf committed
304

thomwolf's avatar
thomwolf committed
305
        output_shape = input_shape + [shape_list(hidden_states)[-1]]
thomwolf's avatar
thomwolf committed
306
307
308
309
310
311

        presents = ()
        all_attentions = []
        all_hidden_states = ()
        for i, (block, layer_past) in enumerate(zip(self.h, past)):
            if self.output_hidden_states:
thomwolf's avatar
thomwolf committed
312
313
314
                all_hidden_states = all_hidden_states + (tf.reshape(hidden_states, output_shape),)

            outputs = block([hidden_states, layer_past, attention_mask, head_mask[i]], training=training)
thomwolf's avatar
thomwolf committed
315
316
317

            hidden_states, present = outputs[:2]
            presents = presents + (present,)
thomwolf's avatar
WIP  
thomwolf committed
318

thomwolf's avatar
thomwolf committed
319
320
321
322
323
            if self.output_attentions:
                all_attentions.append(outputs[2])

        hidden_states = self.ln_f(hidden_states)

thomwolf's avatar
thomwolf committed
324
        hidden_states = tf.reshape(hidden_states, output_shape)
thomwolf's avatar
thomwolf committed
325
326
327
328
329
330
331
332
333
        # Add last hidden state
        if self.output_hidden_states:
            all_hidden_states = all_hidden_states + (hidden_states,)

        outputs = (hidden_states, presents)
        if self.output_hidden_states:
            outputs = outputs + (all_hidden_states,)
        if self.output_attentions:
            # let the number of heads free (-1) so we can extract attention even after head pruning
thomwolf's avatar
thomwolf committed
334
335
            attention_output_shape = input_shape[:-1] + [-1] + shape_list(all_attentions[0])[-2:]
            all_attentions = tuple(tf.reshape(t, attention_output_shape) for t in all_attentions)
thomwolf's avatar
thomwolf committed
336
337
338
            outputs = outputs + (all_attentions,)
        return outputs  # last hidden state, presents, (all hidden_states), (attentions)

thomwolf's avatar
thomwolf committed
339

thomwolf's avatar
thomwolf committed
340
class TFGPT2PreTrainedModel(TFPreTrainedModel):
thomwolf's avatar
WIP  
thomwolf committed
341
342
343
344
    """ An abstract class to handle weights initialization and
        a simple interface for dowloading and loading pretrained models.
    """
    config_class = GPT2Config
thomwolf's avatar
thomwolf committed
345
    pretrained_model_archive_map = TF_GPT2_PRETRAINED_MODEL_ARCHIVE_MAP
346
    load_pt_weights = load_gpt2_pt_weights_in_tf2
thomwolf's avatar
WIP  
thomwolf committed
347
348
349
350
351
352
353
354
355
    base_model_prefix = "transformer"


GPT2_START_DOCSTRING = r"""    OpenAI GPT-2 model was proposed in
    `Language Models are Unsupervised Multitask Learners`_
    by Alec Radford*, Jeffrey Wu*, Rewon Child, David Luan, Dario Amodei** and Ilya Sutskever**.
    It's a causal (unidirectional) transformer pre-trained using  language modeling on a very large
    corpus of ~40 GB of text data.

thomwolf's avatar
thomwolf committed
356
357
    This model is a tf.keras.Model `tf.keras.Model`_ sub-class. Use it as a regular TF 2.0 Keras Model and
    refer to the TF 2.0 documentation for all matter related to general usage and behavior.
thomwolf's avatar
WIP  
thomwolf committed
358
359
360
361

    .. _`Language Models are Unsupervised Multitask Learners`:
        https://openai.com/blog/better-language-models/

thomwolf's avatar
thomwolf committed
362
363
364
    .. _`tf.keras.Model`:
        https://www.tensorflow.org/versions/r2.0/api_docs/python/tf/keras/Model

thomwolf's avatar
thomwolf committed
365
366
367
368
369
370
371
372
373
    Note on the model inputs:
        TF 2.0 models accepts two formats as inputs:

            - having all inputs as keyword arguments (like PyTorch models), or
            - having all inputs as a list, tuple or dict in the first positional arguments.

        This second option is usefull when using `tf.keras.Model.fit()` method which currently requires having all the tensors in the first argument of the model call function: `model(inputs)`.

        If you choose this second option, there are three possibilities you can use to gather all the input Tensors in the first positional argument :
thomwolf's avatar
thomwolf committed
374
375
376
377
378
379

        - a single Tensor with input_ids only and nothing else: `model(inputs_ids)
        - a list of varying length with one or several input Tensors IN THE ORDER given in the docstring:
            `model([input_ids, attention_mask])` or `model([input_ids, attention_mask, token_type_ids])`
        - a dictionary with one or several input Tensors associaed to the input names given in the docstring:
            `model({'input_ids': input_ids, 'token_type_ids': token_type_ids})`
thomwolf's avatar
WIP  
thomwolf committed
380
381
382
383
384
385
386
387

    Parameters:
        config (:class:`~pytorch_transformers.GPT2Config`): Model configuration class with all the parameters of the model.
            Initializing with a config file does not load the weights associated with the model, only the configuration.
            Check out the :meth:`~pytorch_transformers.PreTrainedModel.from_pretrained` method to load the model weights.
"""

GPT2_INPUTS_DOCSTRING = r"""    Inputs:
thomwolf's avatar
thomwolf committed
388
        **input_ids**: ```Numpy array`` or ``tf.Tensor`` of shape ``(batch_size, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
389
390
391
392
393
394
395
            Indices of input sequence tokens in the vocabulary.
            GPT-2 is a model with absolute position embeddings so it's usually advised to pad the inputs on
            the right rather than the left.
            Indices can be obtained using :class:`pytorch_transformers.BPT2Tokenizer`.
            See :func:`pytorch_transformers.PreTrainedTokenizer.encode` and
            :func:`pytorch_transformers.PreTrainedTokenizer.convert_tokens_to_ids` for details.
        **past**:
thomwolf's avatar
thomwolf committed
396
            list of ``Numpy array`` or ``tf.Tensor`` (one for each layer):
thomwolf's avatar
WIP  
thomwolf committed
397
398
            that contains pre-computed hidden-states (key and values in the attention blocks) as computed by the model
            (see `past` output below). Can be used to speed up sequential decoding.
thomwolf's avatar
thomwolf committed
399
        **attention_mask**: (`optional`) ``Numpy array`` or ``tf.Tensor`` of shape ``(batch_size, sequence_length)``:
thomwolf's avatar
thomwolf committed
400
401
402
            Mask to avoid performing attention on padding token indices.
            Mask values selected in ``[0, 1]``:
            ``1`` for tokens that are NOT MASKED, ``0`` for MASKED tokens.
thomwolf's avatar
thomwolf committed
403
        **token_type_ids**: (`optional`) ```Numpy array`` or ``tf.Tensor`` of shape ``(batch_size, sequence_length)``:
thomwolf's avatar
thomwolf committed
404
405
406
            A parallel sequence of tokens (can be used to indicate various portions of the inputs).
            The embeddings from these tokens will be summed with the respective token embeddings.
            Indices are selected in the vocabulary (unlike BERT which has a specific vocabulary for segment indices).
thomwolf's avatar
thomwolf committed
407
        **position_ids**: (`optional`) ```Numpy array`` or ``tf.Tensor`` of shape ``(batch_size, sequence_length)``:
thomwolf's avatar
thomwolf committed
408
409
            Indices of positions of each input sequence tokens in the position embeddings.
            Selected in the range ``[0, config.max_position_embeddings - 1]``.
thomwolf's avatar
thomwolf committed
410
        **head_mask**: (`optional`) ``Numpy array`` or ``tf.Tensor`` of shape ``(num_heads,)`` or ``(num_layers, num_heads)``:
thomwolf's avatar
WIP  
thomwolf committed
411
412
413
414
415
416
417
            Mask to nullify selected heads of the self-attention modules.
            Mask values selected in ``[0, 1]``:
            ``1`` indicates the head is **not masked**, ``0`` indicates the head is **masked**.
"""

@add_start_docstrings("The bare GPT2 Model transformer outputing raw hidden-states without any specific head on top.",
                      GPT2_START_DOCSTRING, GPT2_INPUTS_DOCSTRING)
thomwolf's avatar
thomwolf committed
418
class TFGPT2Model(TFGPT2PreTrainedModel):
thomwolf's avatar
WIP  
thomwolf committed
419
420
    r"""
    Outputs: `Tuple` comprising various elements depending on the configuration (config) and inputs:
thomwolf's avatar
thomwolf committed
421
        **last_hidden_state**: `tf.Tensor`` of shape ``(batch_size, sequence_length, hidden_size)``
thomwolf's avatar
WIP  
thomwolf committed
422
423
            Sequence of hidden-states at the last layer of the model.
        **past**:
thomwolf's avatar
thomwolf committed
424
            list of `tf.Tensor`` (one for each layer) of shape ``(batch_size, num_heads, sequence_length, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
425
426
427
            that contains pre-computed hidden-states (key and values in the attention blocks).
            Can be used (see `past` input) to speed up sequential decoding.
        **hidden_states**: (`optional`, returned when ``config.output_hidden_states=True``)
thomwolf's avatar
thomwolf committed
428
            list of `tf.Tensor`` (one for the output of each layer + the output of the embeddings)
thomwolf's avatar
WIP  
thomwolf committed
429
430
431
            of shape ``(batch_size, sequence_length, hidden_size)``:
            Hidden-states of the model at the output of each layer plus the initial embedding outputs.
        **attentions**: (`optional`, returned when ``config.output_attentions=True``)
thomwolf's avatar
thomwolf committed
432
            list of `tf.Tensor`` (one for each layer) of shape ``(batch_size, num_heads, sequence_length, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
433
434
435
436
            Attentions weights after the attention softmax, used to compute the weighted average in the self-attention heads.

    Examples::

thomwolf's avatar
thomwolf committed
437
438
439
        import tensorflow as tf
        from pytorch_transformers import GPT2Tokenizer, TFGPT2Model

thomwolf's avatar
WIP  
thomwolf committed
440
        tokenizer = GPT2Tokenizer.from_pretrained('gpt2')
thomwolf's avatar
thomwolf committed
441
442
        model = TFGPT2Model.from_pretrained('gpt2')
        input_ids = tf.constant(tokenizer.encode("Hello, my dog is cute"))[None, :]  # Batch size 1
thomwolf's avatar
WIP  
thomwolf committed
443
444
445
446
        outputs = model(input_ids)
        last_hidden_states = outputs[0]  # The last hidden-state is the first element of the output tuple

    """
thomwolf's avatar
thomwolf committed
447
448
    def __init__(self, config, *inputs, **kwargs):
        super(TFGPT2Model, self).__init__(config, *inputs, **kwargs)
thomwolf's avatar
thomwolf committed
449
        self.transformer = TFGPT2MainLayer(config, name='transformer')
thomwolf's avatar
thomwolf committed
450

thomwolf's avatar
thomwolf committed
451
452
    def call(self, inputs, **kwargs):
        outputs = self.transformer(inputs, **kwargs)
thomwolf's avatar
thomwolf committed
453
        return outputs
thomwolf's avatar
WIP  
thomwolf committed
454
455
456
457


@add_start_docstrings("""The GPT2 Model transformer with a language modeling head on top
(linear layer with weights tied to the input embeddings). """, GPT2_START_DOCSTRING, GPT2_INPUTS_DOCSTRING)
thomwolf's avatar
thomwolf committed
458
class TFGPT2LMHeadModel(TFGPT2PreTrainedModel):
thomwolf's avatar
WIP  
thomwolf committed
459
460
    r"""
    Outputs: `Tuple` comprising various elements depending on the configuration (config) and inputs:
thomwolf's avatar
thomwolf committed
461
        **prediction_scores**: `tf.Tensor`` of shape ``(batch_size, sequence_length, config.vocab_size)``
thomwolf's avatar
WIP  
thomwolf committed
462
463
            Prediction scores of the language modeling head (scores for each vocabulary token before SoftMax).
        **past**:
thomwolf's avatar
thomwolf committed
464
            list of `tf.Tensor`` (one for each layer) of shape ``(batch_size, num_heads, sequence_length, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
465
466
467
            that contains pre-computed hidden-states (key and values in the attention blocks).
            Can be used (see `past` input) to speed up sequential decoding.
        **hidden_states**: (`optional`, returned when ``config.output_hidden_states=True``)
thomwolf's avatar
thomwolf committed
468
            list of `tf.Tensor`` (one for the output of each layer + the output of the embeddings)
thomwolf's avatar
WIP  
thomwolf committed
469
470
471
            of shape ``(batch_size, sequence_length, hidden_size)``:
            Hidden-states of the model at the output of each layer plus the initial embedding outputs.
        **attentions**: (`optional`, returned when ``config.output_attentions=True``)
thomwolf's avatar
thomwolf committed
472
            list of `tf.Tensor`` (one for each layer) of shape ``(batch_size, num_heads, sequence_length, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
473
474
475
476
            Attentions weights after the attention softmax, used to compute the weighted average in the self-attention heads.

    Examples::

thomwolf's avatar
thomwolf committed
477
478
        import tensorflow as tf
        from pytorch_transformers import GPT2Tokenizer, TFGPT2LMHeadModel
thomwolf's avatar
WIP  
thomwolf committed
479
480

        tokenizer = GPT2Tokenizer.from_pretrained('gpt2')
thomwolf's avatar
thomwolf committed
481
        model = TFGPT2LMHeadModel.from_pretrained('gpt2')
thomwolf's avatar
WIP  
thomwolf committed
482

thomwolf's avatar
thomwolf committed
483
        input_ids = tf.constant(tokenizer.encode("Hello, my dog is cute"))[None, :]  # Batch size 1
thomwolf's avatar
thomwolf committed
484
        outputs = model(input_ids)
thomwolf's avatar
thomwolf committed
485
        logits = outputs[0]
thomwolf's avatar
WIP  
thomwolf committed
486
487

    """
thomwolf's avatar
thomwolf committed
488
489
490
    def __init__(self, config, *inputs, **kwargs):
        super(TFGPT2LMHeadModel, self).__init__(config, *inputs, **kwargs)
        self.transformer = TFGPT2MainLayer(config, name='transformer')
thomwolf's avatar
WIP  
thomwolf committed
491

thomwolf's avatar
thomwolf committed
492
493
    def call(self, inputs, **kwargs):
        transformer_outputs = self.transformer(inputs, **kwargs)
thomwolf's avatar
WIP  
thomwolf committed
494
495
        hidden_states = transformer_outputs[0]

thomwolf's avatar
thomwolf committed
496
        lm_logits = self.transformer.wte(hidden_states, mode="linear")
thomwolf's avatar
WIP  
thomwolf committed
497
498
499

        outputs = (lm_logits,) + transformer_outputs[1:]

thomwolf's avatar
thomwolf committed
500
        return outputs  # lm_logits, presents, (all hidden_states), (attentions)
thomwolf's avatar
WIP  
thomwolf committed
501
502
503
504
505
506


@add_start_docstrings("""The GPT2 Model transformer with a language modeling and a multiple-choice classification
head on top e.g. for RocStories/SWAG tasks. The two heads are two linear layers.
The language modeling head has its weights tied to the input embeddings,
the classification head takes as input the input of a specified classification token index in the input sequence).
thomwolf's avatar
thomwolf committed
507
508
509
""", GPT2_START_DOCSTRING, GPT2_INPUTS_DOCSTRING)
class TFGPT2DoubleHeadsModel(TFGPT2PreTrainedModel):
    r"""
thomwolf's avatar
thomwolf committed
510
        **mc_token_ids**: (`optional`, default to index of the last token of the input) ``Numpy array`` or ``tf.Tensor`` of shape ``(batch_size, num_choices)``:
thomwolf's avatar
WIP  
thomwolf committed
511
512
513
514
            Index of the classification token in each input sequence.
            Selected in the range ``[0, input_ids.size(-1) - 1[``.

    Outputs: `Tuple` comprising various elements depending on the configuration (config) and inputs:
thomwolf's avatar
thomwolf committed
515
        **lm_prediction_scores**: `tf.Tensor`` of shape ``(batch_size, num_choices, sequence_length, config.vocab_size)``
thomwolf's avatar
WIP  
thomwolf committed
516
            Prediction scores of the language modeling head (scores for each vocabulary token before SoftMax).
thomwolf's avatar
thomwolf committed
517
        **mc_prediction_scores**: `tf.Tensor`` of shape ``(batch_size, num_choices)``
thomwolf's avatar
WIP  
thomwolf committed
518
519
            Prediction scores of the multiplechoice classification head (scores for each choice before SoftMax).
        **past**:
thomwolf's avatar
thomwolf committed
520
            list of `tf.Tensor`` (one for each layer) of shape ``(batch_size, num_heads, sequence_length, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
521
522
523
            that contains pre-computed hidden-states (key and values in the attention blocks).
            Can be used (see `past` input) to speed up sequential decoding.
        **hidden_states**: (`optional`, returned when ``config.output_hidden_states=True``)
thomwolf's avatar
thomwolf committed
524
            list of `tf.Tensor`` (one for the output of each layer + the output of the embeddings)
thomwolf's avatar
WIP  
thomwolf committed
525
526
527
            of shape ``(batch_size, sequence_length, hidden_size)``:
            Hidden-states of the model at the output of each layer plus the initial embedding outputs.
        **attentions**: (`optional`, returned when ``config.output_attentions=True``)
thomwolf's avatar
thomwolf committed
528
            list of `tf.Tensor`` (one for each layer) of shape ``(batch_size, num_heads, sequence_length, sequence_length)``:
thomwolf's avatar
WIP  
thomwolf committed
529
530
531
532
            Attentions weights after the attention softmax, used to compute the weighted average in the self-attention heads.

    Examples::

thomwolf's avatar
thomwolf committed
533
534
535
        import tensorflow as tf
        from pytorch_transformers import GPT2Tokenizer, TFGPT2DoubleHeadsModel

thomwolf's avatar
WIP  
thomwolf committed
536
        tokenizer = GPT2Tokenizer.from_pretrained('gpt2')
thomwolf's avatar
thomwolf committed
537
        model = TFGPT2DoubleHeadsModel.from_pretrained('gpt2')
thomwolf's avatar
WIP  
thomwolf committed
538
539
        
        # Add a [CLS] to the vocabulary (we should train it also!)
thomwolf's avatar
thomwolf committed
540
541
        # This option is currently not implemented in TF 2.0
        raise NotImplementedError
thomwolf's avatar
WIP  
thomwolf committed
542
543
544
545
546
547
548
549
        tokenizer.add_special_tokens({'cls_token': '[CLS]'})
        model.resize_token_embeddings(len(tokenizer))  # Update the model embeddings with the new vocabulary size
        print(tokenizer.cls_token_id, len(tokenizer))  # The newly token the last token of the vocabulary
        
        choices = ["Hello, my dog is cute [CLS]", "Hello, my cat is cute [CLS]"]
        encoded_choices = [tokenizer.encode(s) for s in choices]
        cls_token_location = [tokens.index(tokenizer.cls_token_id) for tokens in encoded_choices]

thomwolf's avatar
thomwolf committed
550
551
        input_ids = tf.constant(encoded_choices)[None, :]  # Batch size: 1, number of choices: 2
        mc_token_ids = tf.constant([cls_token_location])  # Batch size: 1
thomwolf's avatar
WIP  
thomwolf committed
552
553
554
555
556

        outputs = model(input_ids, mc_token_ids=mc_token_ids)
        lm_prediction_scores, mc_prediction_scores = outputs[:2]

    """
thomwolf's avatar
thomwolf committed
557
558
559
560
561
    def __init__(self, config, *inputs, **kwargs):
        super(TFGPT2DoubleHeadsModel, self).__init__(config, *inputs, **kwargs)
        self.transformer = TFGPT2MainLayer(config, name='transformer')
        self.multiple_choice_head = TFSequenceSummary(config, name='multiple_choice_head')

thomwolf's avatar
thomwolf committed
562
563
    def call(self, inputs, past=None, attention_mask=None, token_type_ids=None, position_ids=None, head_mask=None, mc_token_ids=None, training=False):
        if isinstance(inputs, (tuple, list)):
thomwolf's avatar
thomwolf committed
564
            input_ids = inputs[0]
thomwolf's avatar
thomwolf committed
565
566
567
568
569
570
            past = inputs[1] if len(inputs) > 1 else past
            attention_mask = inputs[2] if len(inputs) > 2 else attention_mask
            token_type_ids = inputs[3] if len(inputs) > 3 else token_type_ids
            position_ids = inputs[4] if len(inputs) > 4 else position_ids
            head_mask = inputs[5] if len(inputs) > 5 else head_mask
            mc_token_ids = inputs[6] if len(inputs) > 6 else mc_token_ids
thomwolf's avatar
thomwolf committed
571
            assert len(inputs) <= 7, "Too many inputs."
thomwolf's avatar
thomwolf committed
572
        elif isinstance(inputs, dict):
thomwolf's avatar
thomwolf committed
573
            input_ids = inputs.get('input_ids')
thomwolf's avatar
thomwolf committed
574
575
576
577
578
579
            past = inputs.get('past', past)
            attention_mask = inputs.get('attention_mask', attention_mask)
            token_type_ids = inputs.get('token_type_ids', token_type_ids)
            position_ids = inputs.get('position_ids', position_ids)
            head_mask = inputs.get('head_mask', head_mask)
            mc_token_ids = inputs.get('mc_token_ids', mc_token_ids)
thomwolf's avatar
thomwolf committed
580
            assert len(inputs) <= 7, "Too many inputs."
thomwolf's avatar
thomwolf committed
581
582
        else:
            input_ids = inputs
thomwolf's avatar
thomwolf committed
583

584
585
586
        input_shapes = shape_list(input_ids)

        seq_length = input_shapes[-1]
thomwolf's avatar
thomwolf committed
587
588
589
590
591
592
593
594

        flat_input_ids = tf.reshape(input_ids, (-1, seq_length))
        flat_attention_mask = tf.reshape(attention_mask, (-1, seq_length)) if attention_mask is not None else None
        flat_token_type_ids = tf.reshape(token_type_ids, (-1, seq_length)) if token_type_ids is not None else None
        flat_position_ids = tf.reshape(position_ids, (-1, seq_length)) if position_ids is not None else None

        flat_inputs = [flat_input_ids, past, flat_attention_mask, flat_token_type_ids, flat_position_ids, head_mask]

595
        transformer_outputs = self.transformer(flat_inputs, training=training)
thomwolf's avatar
WIP  
thomwolf committed
596
597
        hidden_states = transformer_outputs[0]

598
599
        hidden_states = tf.reshape(hidden_states, input_shapes + shape_list(hidden_states)[-1:])

thomwolf's avatar
thomwolf committed
600
601
        lm_logits = self.transformer.wte(hidden_states, mode="linear")
        mc_logits = self.multiple_choice_head([hidden_states, mc_token_ids], training=training)
thomwolf's avatar
WIP  
thomwolf committed
602

603
604
        mc_logits = tf.squeeze(mc_logits, axis=-1)

thomwolf's avatar
WIP  
thomwolf committed
605
606
        outputs = (lm_logits, mc_logits) + transformer_outputs[1:]

thomwolf's avatar
thomwolf committed
607
        return outputs  # lm logits, mc logits, presents, (all hidden_states), (attentions)