| 37 | self.model = set(self.model) |
| 38 | |
| 39 | async def learn(self, facts, link, blob, operation=None): |
| 40 | decoded_blob = b64decode(blob).decode('utf-8') |
| 41 | |
| 42 | found_facts = [] |
| 43 | for parser in self.parsers: |
| 44 | try: |
| 45 | for fact in parser.parse(decoded_blob): |
| 46 | found_facts.append(fact) |
| 47 | except Exception as e: |
| 48 | self.log.error(e) |
| 49 | await update_scores(operation=None, increment=len(found_facts), used=facts, facts=link.facts) |
| 50 | await self._store_results(link, found_facts, operation) |
| 51 | |
| 52 | async def _store_results(self, link, facts, operation=None): |
| 53 | facts_covered = [] |