(self, result, parser, source_facts)
| 248 | return task |
| 249 | |
| 250 | async def _parse_link_result(self, result, parser, source_facts): |
| 251 | blob = b64decode(result).decode('utf-8') |
| 252 | parser_info = dict(module=parser.module, used_facts=self.used, mappers=parser.parserconfigs, |
| 253 | source_facts=source_facts) |
| 254 | p_inst = await self._load_module('Parser', parser_info) |
| 255 | return p_inst.parse(blob=blob) |
| 256 | |
| 257 | @staticmethod |
| 258 | async def _load_module(module_type, module_info): |
no test coverage detected