(
self,
node: Optional[str] = None,
in_pool: bool = True,
)
| 90 | self.query = query |
| 91 | |
| 92 | async def run( |
| 93 | self, |
| 94 | node: Optional[str] = None, |
| 95 | in_pool: bool = True, |
| 96 | ) -> OptionalDict: |
| 97 | rows = await self.query.run( |
| 98 | node=node, in_pool=in_pool, use_callbacks=False |
| 99 | ) |
| 100 | results = rows[0] if rows else None |
| 101 | |
| 102 | modified_response = await self.query.callback_delegate.invoke( |
| 103 | results=results, kind=CallbackType.success |
| 104 | ) |
| 105 | return modified_response |
| 106 | |
| 107 | |
| 108 | class SelectList(Proxy["Select", list]): |
no test coverage detected