Method
run
(
self,
node: Optional[str] = None,
in_pool: bool = True,
use_callbacks: bool = True,
**kwargs,
)
Source from the content-addressed store, hash-verified
| 679 | return [querystring] |
| 680 | |
| 681 | async def run( |
| 682 | self, |
| 683 | node: Optional[str] = None, |
| 684 | in_pool: bool = True, |
| 685 | use_callbacks: bool = True, |
| 686 | **kwargs, |
| 687 | ) -> list[dict[str, Any]]: |
| 688 | results = await super().run(node=node, in_pool=in_pool) |
| 689 | if use_callbacks: |
| 690 | return await self.callback_delegate.invoke( |
| 691 | results, kind=CallbackType.success |
| 692 | ) |
| 693 | else: |
| 694 | return results |
| 695 | |
| 696 | |
| 697 | Self = TypeVar("Self", bound=Select) |
Callers
nothing calls this directly
Tested by
no test coverage detected