def reduce_metrics(cls, logging_outputs):
        """Aggregate logging outputs from data parallel training."""
        agg_logging_outputs = cls.aggregate_logging_outputs(logging_outputs)
        for k, v in agg_logging_outputs.items():
            if k in {'nsentences', 'ntokens', 'sample_size'}:
                continue
            metrics.log_scalar(k, v, round=3)
Aggregate logging outputs from data parallel training.
understand_icl/fairseq/examples/speech_text_joint_to_text/criterions/text_guide_cross_entropy_acc.py