temporalio.workflow._asyncio

module documentation
(source)

Undocumented

Function as_completed Return an iterator whose values are coroutines.
Async Function wait Wait for the Futures or Tasks given by fs to complete.
def as_completed(fs: Iterable[Awaitable[AnyType]], *, timeout: float | None = None) -> Iterator[Awaitable[AnyType]]: (source)

Return an iterator whose values are coroutines.

This is a deterministic version of asyncio.as_completed. This function should be used instead of that one in workflows.

async def wait(fs: Iterable[_FT], *, timeout: float | None = None, return_when: str = asyncio.ALL_COMPLETED) -> tuple[list[_FT], list[_FT]]:
async def wait(fs: Iterable[asyncio.Task[AnyType]], *, timeout: float | None = None, return_when: str = asyncio.ALL_COMPLETED) -> tuple[list[asyncio.Task[AnyType]], list[asyncio.Task[AnyType]]]:
(source)

Wait for the Futures or Tasks given by fs to complete.

This is a deterministic version of asyncio.wait. This function should be used instead of that one in workflows.