From 58b6154a73331a8807127d4579ed473432ce88de Mon Sep 17 00:00:00 2001
From: 游雁 <zhifu.gzf@alibaba-inc.com>
Date: 星期二, 20 二月 2024 17:02:44 +0800
Subject: [PATCH] update
---
funasr/train_utils/trainer.py | 24 +++++++++++++-----------
1 files changed, 13 insertions(+), 11 deletions(-)
diff --git a/funasr/train_utils/trainer.py b/funasr/train_utils/trainer.py
index cf997a4..f99161a 100644
--- a/funasr/train_utils/trainer.py
+++ b/funasr/train_utils/trainer.py
@@ -69,6 +69,7 @@
self.device = next(model.parameters()).device
self.avg_nbest_model = kwargs.get("avg_nbest_model", 5)
self.kwargs = kwargs
+ self.log_interval = kwargs.get("log_interval", 50)
try:
@@ -274,8 +275,8 @@
- if self.local_rank == 0:
- pbar.update(1)
+ if batch_idx % self.log_interval == 0 or batch_idx == len(self.dataloader_train) - 1:
+ pbar.update(self.log_interval)
gpu_info = "GPU, memory: {:.3f} GB, " \
"{:.3f} GB, "\
"{:.3f} GB, "\
@@ -285,23 +286,23 @@
torch.cuda.max_memory_reserved()/1024/1024/1024,
)
description = (
+ f"rank: {self.local_rank}, "
f"Train epoch: {epoch}/{self.max_epoch}, "
f"step {batch_idx}/{len(self.dataloader_train)}, "
f"{speed_stats}, "
f"(loss: {loss.detach().cpu().item():.3f}), "
f"{[(k, round(v.cpu().item(), 3)) for k, v in stats.items()]}"
f"{gpu_info}"
- f"rank: {self.local_rank}"
)
pbar.set_description(description)
if self.writer:
- self.writer.add_scalar('Loss/train', loss.item(),
+ self.writer.add_scalar(f'rank{self.local_rank}, Loss/train', loss.item(),
epoch*len(self.dataloader_train) + batch_idx)
for key, var in stats.items():
- self.writer.add_scalar(f'{key}/train', var.item(),
+ self.writer.add_scalar(f'rank{self.local_rank}, {key}/train', var.item(),
epoch * len(self.dataloader_train) + batch_idx)
for key, var in speed_stats.items():
- self.writer.add_scalar(f'{key}/train', eval(var),
+ self.writer.add_scalar(f'rank{self.local_rank}, {key}/train', eval(var),
epoch * len(self.dataloader_train) + batch_idx)
# if batch_idx == 2:
@@ -347,9 +348,10 @@
time4 = time.perf_counter()
- if self.local_rank == 0:
- pbar.update(1)
+ if batch_idx % self.log_interval == 0 or batch_idx == len(self.dataloader_train) - 1:
+ pbar.update(self.log_interval)
description = (
+ f"rank: {self.local_rank}, "
f"validation epoch: {epoch}/{self.max_epoch}, "
f"step {batch_idx}/{len(self.dataloader_train)}, "
f"{speed_stats}, "
@@ -359,11 +361,11 @@
)
pbar.set_description(description)
if self.writer:
- self.writer.add_scalar('Loss/val', loss.item(),
+ self.writer.add_scalar(f"rank{self.local_rank}, Loss/val", loss.item(),
epoch*len(self.dataloader_train) + batch_idx)
for key, var in stats.items():
- self.writer.add_scalar(f'{key}/val', var.item(),
+ self.writer.add_scalar(f'rank{self.local_rank}, {key}/val', var.item(),
epoch * len(self.dataloader_train) + batch_idx)
for key, var in speed_stats.items():
- self.writer.add_scalar(f'{key}/val', eval(var),
+ self.writer.add_scalar(f'rank{self.local_rank}, {key}/val', eval(var),
epoch * len(self.dataloader_train) + batch_idx)
\ No newline at end of file
--
Gitblit v1.9.1