| 409 | return event_dict |
| 410 | |
| 411 | async def _init_source(self): |
| 412 | # seed knowledge_svc with source facts |
| 413 | if self.source: |
| 414 | knowledge_svc_handle = BaseService.get_service('knowledge_svc') |
| 415 | for f in self.source.facts: |
| 416 | f.origin_type = OriginType.SEEDED |
| 417 | f.source = self.source.id |
| 418 | await knowledge_svc_handle.add_fact(f) |
| 419 | for r in self.source.relationships: |
| 420 | r.origin = self.source.id |
| 421 | await knowledge_svc_handle.add_relationship(r) |
| 422 | |
| 423 | async def _cleanup_operation(self, services): |
| 424 | cleanup_count = 0 |