(self)
| 358 | await asyncio.gather(*tasks) |
| 359 | |
| 360 | async def _insert_done(self): |
| 361 | tasks = [] |
| 362 | for storage_inst in [ |
| 363 | self.full_docs, |
| 364 | self.text_chunks, |
| 365 | self.llm_response_cache, |
| 366 | self.community_reports, |
| 367 | self.entities_vdb, |
| 368 | self.chunks_vdb, |
| 369 | self.chunk_entity_relation_graph, |
| 370 | ]: |
| 371 | if storage_inst is None: |
| 372 | continue |
| 373 | tasks.append(cast(StorageNameSpace, storage_inst).index_done_callback()) |
| 374 | await asyncio.gather(*tasks) |
| 375 | |
| 376 | async def _query_done(self): |
| 377 | tasks = [] |
no test coverage detected