(self, query: str, param: QueryParam = QueryParam())
| 410 | await self._insert_done() |
| 411 | |
| 412 | def query(self, query: str, param: QueryParam = QueryParam()): |
| 413 | loop = always_get_an_event_loop() |
| 414 | return loop.run_until_complete(self.aquery(query, param)) |
| 415 | |
| 416 | async def aquery(self, query: str, param: QueryParam = QueryParam()): |
| 417 | if param.mode in ["local", "global", "hybrid"]: |
no test coverage detected