Source code for owmeta.data_trans.context_merge

from owmeta_core.datasource import DataTranslator, OneOrMore

from .. import SCI_CTX

from .common_data import DTMixin
from .data_with_evidence_ds import DataWithEvidenceDataSource


class ContextMergeDataTranslator(DTMixin, DataTranslator):
    class_context = SCI_CTX

    input_type = OneOrMore(DataWithEvidenceDataSource)
    output_type = DataWithEvidenceDataSource

    def translate(self, *sources):
        if not sources:
            raise Exception("No sources were provided")

        sources = sorted(sources, key=lambda s: s.identifier)
        res = self.make_new_output(sources=sources)

        for src in sources:
            res.data_context.add_import(src.data_context)
            res.evidence_context.add_import(src.evidence_context)
        return res