```python embedding_layer = embedding_layer.to(DEVICE) transformer_encoder = transformer_encoder.to(DEVICE) pos_encoding = pos_encoding.to(DEVICE) output_layer = output_layer.to(DEVICE) # ----------------------------- # Оптимизатор # ----------------------------- optimizer = torch.optim.Adam( list(embedding_layer.parameters()) + list(transformer_encoder.parameters()) + list(pos_encoding.parameters()) + list(output_layer.parameters()), lr=1e-4 ) # ----------------------------- # Загружаем чекпоинт # ----------------------------- start_epoch = 0 if os.path.exists(CHECKPOINT_PATH): checkpoint = torch.load(CHECKPOINT_PATH, map_location=DEVICE) embedding_layer.load_state_dict(checkpoint['embedding_state']) pos_encoding.load_state_dict(checkpoint['pos_encoding_state']) transformer_encoder.load_state_dict(checkpoint['transformer_state']) output_layer.load_state_dict(checkpoint['output_state']) optimizer.load_state_dict(checkpoint['optimizer_state']) start_epoch = checkpoint['epoch'] + 1 print(f"Модель загружена, продолжаем с эпохи {start_epoch}") else: print("Чекпоинт не найден, начинаем обучение с нуля") # ----------------------------- # Обучение с отладкой # ----------------------------- for epoch in range(start_epoch, start_epoch + EPOCHS): running_loss = 0.0 print(f"\n=== Эпоха {epoch + 1}/{start_epoch + EPOCHS} ===") for chunk_idx, (input_ids_chunk, attention_mask_chunk, target_ids_chunk) in enumerate( chunked_tokenizer(data, tokenizer, max_len=MAX_LEN, chunk_size=CHUNK_SIZE) ): print(f"\n--- Чанк {chunk_idx + 1} / {len(data) // CHUNK_SIZE + 1} ---") dataset = TensorDataset(input_ids_chunk, attention_mask_chunk, target_ids_chunk) dataloader = DataLoader(dataset, batch_size=BATCH_SIZE, shuffle=True) for batch_idx, batch in enumerate(dataloader): batch_input_ids, batch_attention_mask, batch_target_ids = [x.to(DEVICE) for x in batch] padding_mask = (batch_attention_mask == 0) optimizer.zero_grad() # Эмбеддинги embedded = embedding_layer(batch_input_ids) print(f"[DEBUG] embedded shape: {embedded.shape}") # batch, seq_len, embed_dim # Позиционное кодирование embedded = embedded.transpose(0, 1) # seq_len, batch, embed_dim embedded = pos_encoding(embedded) print(f"[DEBUG] embedded + pos_encoding shape: {embedded.shape}") # Трансформер transformer_output = transformer_encoder(embedded, src_key_padding_mask=padding_mask) transformer_output = transformer_output.transpose(0, 1) # batch, seq_len, embed_dim print(f"[DEBUG] transformer_output shape: {transformer_output.shape}") # Память выхода трансформера (примерно) batch_size, seq_len, emb_dim = transformer_output.shape mem_MB = batch_size * seq_len * emb_dim * 4 / 1024 ** 2 print(f"[DEBUG] Output memory approx: {mem_MB:.2f} MB") # Линейный слой logits = output_layer(transformer_output) print(f"[DEBUG] logits shape: {logits.shape}") # Потери loss = criterion(logits.view(-1, vocab_size), batch_target_ids.view(-1)) loss_history.append(loss.item()) print(f"[DEBUG] batch {batch_idx + 1} loss: {loss.item():.6f}") # Backprop loss.backward() optimizer.step() running_loss += loss.item() * batch_input_ids.size(0) # Демонстрация предсказаний pred_tokens = torch.argmax(logits, dim=-1) sample_input = tokenizer.decode(batch_input_ids[0], skip_special_tokens=True) sample_pred = tokenizer.decode(pred_tokens[0], skip_special_tokens=True) sample_target = tokenizer.decode(batch_target_ids[0], skip_special_tokens=True) print(f"[DEBUG] Sample input: {sample_input[:50]}...") print(f"[DEBUG] Sample target: {sample_target[:50]}...") print(f"[DEBUG] Sample pred: {sample_pred[:50]}...") # Очистка памяти del batch_input_ids, batch_attention_mask, batch_target_ids, embedded, transformer_output, logits torch.cuda.empty_cache() avg_loss = running_loss / len(data) print(f"\n=== Эпоха {epoch + 1} завершена — Avg Loss: {avg_loss:.6f} ===\n") # ----------------------------- # Сохраняем чекпоинт # ----------------------------- torch.save({ 'embedding_state': embedding_layer.state_dict(), 'pos_encoding_state': pos_encoding.state_dict(), 'transformer_state': transformer_encoder.state_dict(), 'output_state': output_layer.state_dict(), 'optimizer_state': optimizer.state_dict(), 'epoch': epoch }, CHECKPOINT_PATH)