Source code for q2_cores.SymXchange.mappers.base_mapper

from typing import List

from q2_sdk.models.cores.mappers.base_mapper import BaseMapper

from ...Symitar.models import SymXchangeMessage, parser
from ...SymXchange.queries import SymXchangeBaseQuery




class SymXchangeBaseMapper(BaseMapper):


    @staticmethod
    def parse_returned_queries(
        list_of_queries: List[SymXchangeBaseQuery],
    ) -> SymXchangeMessage:
        assert len(list_of_queries) == 1
        response = list_of_queries[0].raw_core_response
        data = parser.parse(response)
        return data




    async def execute(self) -> SymXchangeMessage:
        return await super().execute()