def _report_total_times()

in esrally/reporter.py [0:0]

• 108 lines of code
• 1 McCabe index (conditional complexity)

    def _report_total_times(self, baseline_stats, contender_stats):
        lines = []
        lines.extend(
            self._report_total_time(
                "indexing time",
                baseline_stats.total_time,
                contender_stats.total_time,
            )
        )
        lines.extend(
            self._report_total_time_per_shard(
                "indexing time",
                baseline_stats.total_time_per_shard,
                contender_stats.total_time_per_shard,
            )
        )
        lines.extend(
            self._report_total_time(
                "indexing throttle time",
                baseline_stats.indexing_throttle_time,
                contender_stats.indexing_throttle_time,
            )
        )
        lines.extend(
            self._report_total_time_per_shard(
                "indexing throttle time",
                baseline_stats.indexing_throttle_time_per_shard,
                contender_stats.indexing_throttle_time_per_shard,
            )
        )
        lines.extend(
            self._report_total_time(
                "merge time",
                baseline_stats.merge_time,
                contender_stats.merge_time,
            )
        )
        lines.extend(
            self._report_total_count(
                "merge count",
                baseline_stats.merge_count,
                contender_stats.merge_count,
            )
        )
        lines.extend(
            self._report_total_time_per_shard(
                "merge time",
                baseline_stats.merge_time_per_shard,
                contender_stats.merge_time_per_shard,
            )
        )
        lines.extend(
            self._report_total_time(
                "merge throttle time",
                baseline_stats.merge_throttle_time,
                contender_stats.merge_throttle_time,
            )
        )
        lines.extend(
            self._report_total_time_per_shard(
                "merge throttle time",
                baseline_stats.merge_throttle_time_per_shard,
                contender_stats.merge_throttle_time_per_shard,
            )
        )
        lines.extend(
            self._report_total_time(
                "refresh time",
                baseline_stats.refresh_time,
                contender_stats.refresh_time,
            )
        )
        lines.extend(
            self._report_total_count(
                "refresh count",
                baseline_stats.refresh_count,
                contender_stats.refresh_count,
            )
        )
        lines.extend(
            self._report_total_time_per_shard(
                "refresh time",
                baseline_stats.refresh_time_per_shard,
                contender_stats.refresh_time_per_shard,
            )
        )
        lines.extend(
            self._report_total_time(
                "flush time",
                baseline_stats.flush_time,
                contender_stats.flush_time,
            )
        )
        lines.extend(
            self._report_total_count(
                "flush count",
                baseline_stats.flush_count,
                contender_stats.flush_count,
            )
        )
        lines.extend(
            self._report_total_time_per_shard(
                "flush time",
                baseline_stats.flush_time_per_shard,
                contender_stats.flush_time_per_shard,
            )
        )
        return lines