| 20 | return getattr(module, module_type)(module_info) |
| 21 | |
| 22 | async def add_fact(self, fact, constraints=None): |
| 23 | if isinstance(fact, Fact): |
| 24 | await self.get_service('event_svc').fire_event(exchange='fact', queue='added', fact=fact.display, constraints=constraints) |
| 25 | return await self.__loaded_knowledge_module._add_fact(fact, constraints) |
| 26 | |
| 27 | async def update_fact(self, criteria, updates): |
| 28 | await self.get_service('event_svc').fire_event(exchange='fact', queue='updated', criteria=criteria, updates=updates) |