Source code for ores.scoring_systems.single_thread

import logging

from .scoring_system import ScoringSystem

logger = logging.getLogger(__name__)


class SingleThread(ScoringSystem):

    def _process_missing_scores(self, request, missing_model_set_revs,
                                root_caches, inprogress_results=None):
        rev_scores = {}
        errors = {}

        for missing_models, rev_ids in missing_model_set_revs.items():
            for rev_id in rev_ids:
                if rev_id not in root_caches:
                    continue
                root_cache = root_caches[rev_id]
                try:
                    score_map = self._process_score_map(
                        request, rev_id, missing_models, root_cache)
                    rev_scores[rev_id] = score_map
                except Exception as error:
                    errors[rev_id] = error

        return rev_scores, errors

    @classmethod
    def from_config(cls, config, name, section_key="scoring_systems"):
        logger.info("Loading SingleThread '{0}' from config.".format(name))
        kwargs = cls._kwargs_from_config(
            config, name, section_key=section_key)
        return cls(**kwargs)