3 # Any copyright is dedicated to the Public Domain.
4 # https://creativecommons.org/publicdomain/zero/1.0/
6 # Written by Francois Fleuret <francois@fleuret.org>
8 import math, os, tqdm, warnings
10 import torch, torchvision
13 from torch.nn import functional as F
16 from mygpt import BracketedSequence
18 ######################################################################
20 # ar_mask is a tensor with 0s and 1s, of same shape as input, with
21 # 1s where tokens should be generated. The others are kept
25 def one_batch_masked_inplace_autoregression(
31 deterministic_synthesis=False,
33 to_generate = (ar_mask.sum(0) > 0).nonzero()
35 if to_generate.min() > 0:
37 BracketedSequence(input, 0, to_generate.min())
38 ) # Needed to initialize the model's cache
39 for s in range(to_generate.min(), to_generate.max() + 1):
40 output = model(BracketedSequence(input, s, 1)).x
44 logits = (logits / temperature).log_softmax(dim=-1)
46 if deterministic_synthesis:
47 t_next = logits.argmax(-1)
49 dist = torch.distributions.categorical.Categorical(logits=logits)
50 t_next = dist.sample()
52 all_n = torch.arange(t_next.size(0))
53 seq_logproba += logits[all_n, t_next].sum(dim=-1)
55 input[:, s] = ar_mask[:, s] * t_next + (1 - ar_mask[:, s]) * input[:, s]
58 def masked_inplace_autoregression(
65 deterministic_synthesis,
66 forbidden_tokens=None,
68 progress_bar_desc=None,
69 device=torch.device("cpu"),
71 assert input.size() == ar_mask.size()
74 input.split(batch_size),
75 ar_mask.split(batch_size),
76 seq_logproba.split(batch_size),
79 if progress_bar_desc is not None:
83 desc=progress_bar_desc,
84 total=(input.size(0) + batch_size - 1) // batch_size,
87 with torch.autograd.no_grad():
91 for input, ar_mask, seq_logproba in batches:
92 one_batch_masked_inplace_autoregression(
96 seq_logproba=seq_logproba,
97 temperature=temperature,
98 deterministic_synthesis=deterministic_synthesis,
104 ######################################################################
108 def indices_forward_and_backward(self, quizzes):
109 i_forward = quizzes[:, 0] == self.token_forward
110 j_forward = quizzes[:, 1 + self.prompt_len] == self.token_forward
111 i_backward = quizzes[:, 0] == self.token_backward
112 j_backward = quizzes[:, 1 + self.answer_len] == self.token_backward
113 assert torch.logical_or(
114 torch.logical_and(i_forward, j_forward),
115 torch.logical_and(i_backward, j_backward),
117 return i_forward, i_backward
119 def reverse_time(self, quizzes):
120 i_forward, i_backward = self.indices_forward_and_backward(quizzes)
122 forward_to_backward = torch.cat(
125 quizzes[:, 2 + self.prompt_len : 2 + self.prompt_len + self.answer_len],
126 quizzes[:, 1 + self.prompt_len : 1 + self.prompt_len + 1],
127 quizzes[:, 1 : 1 + self.prompt_len],
132 forward_to_backward[:, 0] = self.token_backward
133 forward_to_backward[:, 1 + self.answer_len] = self.token_backward
135 backward_to_forward = torch.cat(
138 quizzes[:, 2 + self.answer_len :],
139 quizzes[:, 1 + self.answer_len : 2 + self.answer_len],
140 quizzes[:, 1 : 1 + self.answer_len],
145 backward_to_forward[:, 0] = self.token_forward
146 backward_to_forward[:, 1 + self.prompt_len] = self.token_forward
148 m = i_forward.long()[:, None]
150 return m * forward_to_backward + (1 - m) * backward_to_forward
152 def make_ar_mask(self, quizzes, first=False):
153 i_forward, i_backward = self.indices_forward_and_backward(quizzes)
155 t = torch.arange(quizzes.size(1), device=quizzes.device)
158 m_forward = (t >= 1).long() * (t < 1 + self.prompt_len).long()
159 m_backward = (t >= 1).long() * (t < 1 + self.answer_len).long()
161 m_forward = (t >= 2 + self.prompt_len).long()
162 m_backward = (t >= 2 + self.answer_len).long()
164 m = i_forward.long()[:, None]
166 return m * m_forward + (1 - m) * m_backward
168 def generate_token_sequences(self, nb):
169 prompts, answers = self.problem.generate_prompts_and_answers(nb)
171 if self.prompt_len is None:
172 self.prompt_len = prompts.size(1)
174 if self.answer_len is None:
175 self.answer_len = answers.size(1)
177 assert prompts.size(1) == self.prompt_len and answers.size(1) == self.answer_len
181 for prompt, answer in zip(prompts, answers):
182 if torch.rand(1) < 0.5:
184 torch.tensor([self.token_forward]),
186 torch.tensor([self.token_forward]),
191 torch.tensor([self.token_backward]),
193 torch.tensor([self.token_backward]),
197 result.append(torch.cat(a, dim=0)[None, :])
199 return torch.cat(result, dim=0)
210 device=torch.device("cpu"),
214 v = problem.nb_token_values()
215 self.token_forward = v
216 self.token_backward = v + 1
217 self.nb_token_values = v + 2
219 self.problem = problem
220 self.back_accuracy = back_accuracy
221 self.batch_size = batch_size
224 self.prompt_len = None
225 self.answer_len = None
227 self.train_w_quizzes = self.generate_token_sequences(nb_train_samples).to(
231 self.test_w_quizzes = self.generate_token_sequences(nb_test_samples).to(device)
233 self.train_c_quizzes = []
234 self.test_c_quizzes = []
236 if result_dir is not None:
240 self.train_w_quizzes[:72],
244 def save_quizzes(self, result_dir, filename_prefix, quizzes, prediction=False):
245 quizzes = quizzes.clone()
246 forward = quizzes[quizzes[:, 0] == self.token_forward]
247 ib = quizzes[:, 0] == self.token_backward
248 backward = quizzes[ib]
249 assert forward.size(0) + backward.size(0) == quizzes.size(0)
250 quizzes[ib] = self.reverse_time(quizzes[ib])
253 predicted_prompts = ib
254 predicted_answers = torch.logical_not(ib)
256 predicted_prompts = None
257 predicted_answers = None
259 self.problem.save_quizzes(
262 quizzes[:, 1 : 1 + self.prompt_len],
263 quizzes[:, 2 + self.prompt_len :],
268 def batches(self, split="train", desc=None):
269 assert split in {"train", "test"}
271 w_quizzes = self.train_w_quizzes
272 c_quizzes = self.train_c_quizzes
274 w_quizzes = self.test_w_quizzes
275 c_quizzes = self.test_c_quizzes
277 if len(c_quizzes) > 0:
278 c_quizzes = torch.cat(c_quizzes, dim=0)
279 if c_quizzes.size(0) > w_quizzes.size(0) // 2:
280 i = torch.randperm(c_quizzes.size(0))[: w_quizzes.size(0) // 2]
281 c_quizzes = c_quizzes[i]
283 i = torch.randperm(w_quizzes.size(0))[
284 : w_quizzes.size(0) - c_quizzes.size(0)
286 w_quizzes = w_quizzes[i]
288 self.nb_batch_w_quizzes = w_quizzes.size(0)
289 self.nb_batch_c_quizzes = c_quizzes.size(0)
291 input = torch.cat([w_quizzes, c_quizzes], dim=0)
294 self.nb_batch_w_quizzes = w_quizzes.size(0)
295 self.nb_batch_c_quizzes = 0
298 input = input[torch.randperm(input.size(0))]
301 desc = f"epoch-{split}"
302 for batch in tqdm.tqdm(
303 input.split(self.batch_size), dynamic_ncols=True, desc=desc
307 def vocabulary_size(self):
308 return self.nb_token_values
311 self, n_epoch, model, result_dir, deterministic_synthesis, nmax=1000
313 def compute_accuracy(input):
314 ar_mask = self.make_ar_mask(input)
315 result = input.clone() * (1 - ar_mask)
316 seq_logproba = torch.empty(input.size(0), device=self.device)
318 masked_inplace_autoregression(
320 batch_size=self.batch_size,
323 seq_logproba=seq_logproba,
325 deterministic_synthesis=deterministic_synthesis,
326 progress_bar_desc=None,
330 #!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
333 f"DEBUG_input_{n_epoch}_{result.size(0):04d}",
339 f"DEBUG_result_{n_epoch}_{result.size(0):04d}",
343 #!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
345 if self.back_accuracy:
346 n_forward = input[:, 0] == self.token_forward
347 nb_total = input[n_forward].size(0)
349 (input[n_forward] == result[n_forward])
357 f"back_accuracy {n_epoch=} {model.id=} {nb_correct=} {nb_total=}"
360 n_backward = input[:, 0] == self.token_backward
361 back_input = self.reverse_time(result[n_backward])
363 if back_input.size(0) > 0:
364 back_input[:, 2 + self.prompt_len :] = input[
365 n_backward, 1 : 1 + self.answer_len
367 back_nb_total, back_nb_correct = compute_accuracy(back_input)
369 f"back_accuracy {n_epoch=} {model.id=} {back_nb_correct=} {back_nb_total=}"
371 nb_total += back_nb_total
372 nb_correct += back_nb_correct
375 nb_total = input.size(0)
376 nb_correct = (input == result).long().min(dim=1).values.sum()
380 return nb_total, nb_correct
382 train_nb_total, train_nb_correct = compute_accuracy(self.train_w_quizzes[:nmax])
385 f"accuracy_train {n_epoch} nb_total {train_nb_total} nb_correct {train_nb_correct} accuracy {(100.0*train_nb_correct)/train_nb_total:.02f}%"
388 test_nb_total, test_nb_correct = compute_accuracy(self.test_w_quizzes[:nmax])
391 f"accuracy_test {n_epoch} nb_total {test_nb_total} nb_correct {test_nb_correct} accuracy {(100.0*test_nb_correct)/test_nb_total:.02f}%"
394 main_test_accuracy = test_nb_correct / test_nb_total
395 self.logger(f"main_test_accuracy {n_epoch} {main_test_accuracy}")
397 ##############################
399 input = self.test_w_quizzes[:96]
400 ar_mask = self.make_ar_mask(input)
401 result = input.clone() * (1 - ar_mask)
402 seq_logproba = torch.empty(input.size(0), device=self.device)
404 masked_inplace_autoregression(
406 batch_size=self.batch_size,
409 seq_logproba=seq_logproba,
411 deterministic_synthesis=deterministic_synthesis,
412 progress_bar_desc=None,
418 f"culture_prediction_{n_epoch:04d}_{model.id:02d}",
423 return main_test_accuracy
425 def renew_w_quizzes(self, nb, for_train=True):
426 input = self.train_w_quizzes if for_train else self.test_w_quizzes
427 nb = min(nb, input.size(0))
428 input[:-nb] = input[nb:].clone()
429 input[-nb:] = self.generate_token_sequences(nb).to(self.device)
431 def store_c_quizzes(self, new_c_quizzes, for_train=True):
433 self.train_c_quizzes.append(new_c_quizzes)
435 self.test_c_quizzes.append(new_c_quizzes)
437 def compute_correctness(
440 models_for_validation,
441 bidirectional_validation=False,
442 deterministic_validation=True,
444 if bidirectional_validation:
445 backward_c_quizzes = self.forward_to_backward(c_quizzes)
447 seq_logproba = torch.zeros(
449 max([m.id for m in models_for_validation]) + 1,
455 for model in models_for_validation:
456 result = c_quizzes.clone()
458 seq_logproba[...] = 0.0
460 ar_mask = self.make_ar_mask(result)
462 masked_inplace_autoregression(
464 batch_size=self.batch_size,
467 seq_logproba=seq_logproba[:, model.id],
469 deterministic_synthesis=deterministic_validation,
470 # progress_bar_desc="solving c_quizzes",
474 correct = (c_quizzes == result).long().min(dim=-1).values
476 if bidirectional_validation:
477 backward_result = backward_c_quizzes.clone()
479 ar_mask = self.make_ar_mask(backward_result)
481 masked_inplace_autoregression(
483 batch_size=self.batch_size,
484 input=backward_result,
486 seq_logproba=seq_logproba[:, model.id],
488 deterministic_synthesis=deterministic_validation,
489 # progress_bar_desc="solving backward c_quizzes",
494 (backward_c_quizzes == backward_result).long().min(dim=-1).values
497 correct *= backward_correct
501 nb_correct += correct
503 return nb_correct, seq_logproba
505 ###############################################################
507 def generate_quizzes(self, nb, model_for_generation, temperature=1.0):
508 c_quizzes = torch.empty(
509 nb, self.train_w_quizzes.size(1), device=self.device, dtype=torch.int64
512 seq_logproba = torch.zeros(nb, device=self.device)
514 # First, we generate the answer at high temperature
516 c_quizzes[:, 0] = self.token_backward
517 c_quizzes[:, 1 + self.answer_len] = self.token_backward
519 masked_inplace_autoregression(
520 model=model_for_generation,
521 batch_size=self.batch_size,
523 ar_mask=self.make_ar_mask(c_quizzes, first=True),
524 seq_logproba=seq_logproba,
525 temperature=temperature,
526 deterministic_synthesis=False,
530 # Then, we generate the prompt at low temperature
532 masked_inplace_autoregression(
533 model=model_for_generation,
534 batch_size=self.batch_size,
536 ar_mask=self.make_ar_mask(c_quizzes),
537 seq_logproba=seq_logproba,
538 temperature=1 / temperature,
539 deterministic_synthesis=False,
543 # Then we return the quizz, and re-generate the response, now
546 c_quizzes = self.reverse_time(c_quizzes)
548 masked_inplace_autoregression(
549 model=model_for_generation,
550 batch_size=self.batch_size,
552 ar_mask=self.make_ar_mask(c_quizzes),
553 seq_logproba=seq_logproba,
554 temperature=1 / temperature,
555 deterministic_synthesis=False,