workload-automation/wlauto/result_processors/standard.py

#    Copyright 2013-2015 ARM Limited
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#


# pylint: disable=R0201
"""
This module contains a few "standard" result processors that write results to
text files in various formats.

"""
import os
import csv

from wlauto import ResultProcessor, Parameter
from wlauto.exceptions import ConfigError
from wlauto.utils.types import list_of_strings


class StandardProcessor(ResultProcessor):

    name = 'standard'
    description = """
    Creates a ``result.txt`` file for every iteration that contains metrics
    for that iteration.

    The metrics are written in ::

        metric = value [units]

    format.

    """

    def process_iteration_result(self, result, context):
        outfile = os.path.join(context.output_directory, 'result.txt')
        with open(outfile, 'w') as wfh:
            for metric in result.metrics:
                line = '{} = {}'.format(metric.name, metric.value)
                if metric.units:
                    line = ' '.join([line, metric.units])
                line += '\n'
                wfh.write(line)
        context.add_artifact('iteration_result', 'result.txt', 'export')


class CsvReportProcessor(ResultProcessor):
    """
    Creates a ``results.csv`` in the output directory containing results for
    all iterations in CSV format, each line containing a single metric.

    """

    name = 'csv'

    parameters = [
        Parameter('use_all_classifiers', kind=bool, default=False,
                  global_alias='use_all_classifiers',
                  description="""
                  If set to ``True``, this will add a column for every classifier
                  that features in at least one collected metric.

                  .. note:: This cannot be ``True`` if ``extra_columns`` is set.

                  """),
        Parameter('extra_columns', kind=list_of_strings,
                  description="""
                  List of classifiers to use as columns.

                   .. note:: This cannot be set if ``use_all_classifiers`` is ``True``.

                  """),
    ]

    def validate(self):
        if self.use_all_classifiers and self.extra_columns:
            raise ConfigError('extra_columns cannot be specified when use_all_classifiers is True')

    def initialize(self, context):
        self.results_so_far = []  # pylint: disable=attribute-defined-outside-init

    def process_iteration_result(self, result, context):
        self.results_so_far.append(result)
        self._write_results(self.results_so_far, context)

    def process_run_result(self, result, context):
        self._write_results(result.iteration_results, context)
        context.add_artifact('run_result_csv', 'results.csv', 'export')

    def _write_results(self, results, context):
        if self.use_all_classifiers:
            classifiers = set([])
            for ir in results:
                for metric in ir.metrics:
                    classifiers.update(metric.classifiers.keys())
            extra_columns = list(classifiers)
        elif self.extra_columns:
            extra_columns = self.extra_columns
        else:
            extra_columns = []

        outfile = os.path.join(context.run_output_directory, 'results.csv')
        with open(outfile, 'wb') as wfh:
            writer = csv.writer(wfh)
            writer.writerow(['id', 'workload', 'iteration', 'metric', ] +
                            extra_columns + ['value', 'units'])
            for ir in results:
                for metric in ir.metrics:
                    row = ([ir.id, ir.spec.label, ir.iteration, metric.name] +
                           [str(metric.classifiers.get(c, '')) for c in extra_columns] +
                           [str(metric.value), metric.units or ''])
                    writer.writerow(row)


class SummaryCsvProcessor(ResultProcessor):
    """
    Similar to csv result processor, but only contains workloads' summary metrics.

    """

    name = 'summary_csv'

    def process_run_result(self, result, context):
        outfile = os.path.join(context.run_output_directory, 'summary.csv')
        with open(outfile, 'wb') as wfh:
            writer = csv.writer(wfh)
            writer.writerow(['id', 'workload', 'iteration', 'metric', 'value', 'units'])
            for result in result.iteration_results:
                for metric in result.metrics:
                    if metric.name in result.workload.summary_metrics:
                        row = [result.id, result.workload.name, result.iteration,
                               metric.name, str(metric.value), metric.units or '']
                        writer.writerow(row)
        context.add_artifact('run_result_summary', 'summary.csv', 'export')