Skip to main content

infrahub_sdk.batch

Functions​

execute_batch_task_in_pool ​

execute_batch_task_in_pool(task: BatchTask, semaphore: asyncio.Semaphore, return_exceptions: bool = False) -> tuple[InfrahubNode | None, Any]

Classes​

BatchTask ​

BatchTaskSync ​

Methods:

execute ​

execute(self, return_exceptions: bool = False) -> tuple[InfrahubNodeSync | None, Any]

Executes the stored task.

InfrahubBatch ​

Methods:

num_tasks ​

num_tasks(self) -> int

add ​

add(self, *args: Any, **kwargs: Any) -> None

execute ​

execute(self) -> AsyncGenerator

InfrahubBatchSync ​

Methods:

num_tasks ​

num_tasks(self) -> int

add ​

add(self, *args: Any, **kwargs: Any) -> None

execute ​

execute(self) -> Generator[tuple[InfrahubNodeSync | None, Any], None, None]