def _report_transform_processing_times()

in esrally/reporter.py [0:0]

• 61 lines of code
• 14 McCabe index (conditional complexity)

    def _report_transform_processing_times(self, baseline_stats, contender_stats):
        lines = []
        if baseline_stats.total_transform_processing_times is None:
            return lines
        for baseline in baseline_stats.total_transform_processing_times:
            transform_id = baseline["id"]
            for contender in contender_stats.total_transform_processing_times:
                if contender["id"] == transform_id:
                    lines.append(
                        self._line(
                            "Transform processing time",
                            baseline["mean"],
                            contender["mean"],
                            transform_id,
                            baseline["unit"],
                            treat_increase_as_improvement=False,
                        )
                    )
        for baseline in baseline_stats.total_transform_index_times:
            transform_id = baseline["id"]
            for contender in contender_stats.total_transform_index_times:
                if contender["id"] == transform_id:
                    lines.append(
                        self._line(
                            "Transform indexing time",
                            baseline["mean"],
                            contender["mean"],
                            transform_id,
                            baseline["unit"],
                            treat_increase_as_improvement=False,
                        )
                    )
        for baseline in baseline_stats.total_transform_search_times:
            transform_id = baseline["id"]
            for contender in contender_stats.total_transform_search_times:
                if contender["id"] == transform_id:
                    lines.append(
                        self._line(
                            "Transform search time",
                            baseline["mean"],
                            contender["mean"],
                            transform_id,
                            baseline["unit"],
                            treat_increase_as_improvement=False,
                        )
                    )
        for baseline in baseline_stats.total_transform_throughput:
            transform_id = baseline["id"]
            for contender in contender_stats.total_transform_throughput:
                if contender["id"] == transform_id:
                    lines.append(
                        self._line(
                            "Transform throughput",
                            baseline["mean"],
                            contender["mean"],
                            transform_id,
                            baseline["unit"],
                            treat_increase_as_improvement=True,
                        )
                    )
        return lines