temporalio.contrib.aws.s3driver._driver

module documentation
(source)

Amazon S3 storage driver for Temporal external storage.

Warning

This API is experimental.

Function _format_client_context Format the client's describe() output as ", k=v, k=v" for error messages. Returns an empty string when the client reports no metadata or describe itself raises (diagnostic output must never mask the real error).
Async Function _gather_with_cancellation Run coroutines concurrently, cancelling all remaining tasks if one fails.
Type Variable _T Undocumented
def _format_client_context(client: S3StorageDriverClient) -> str: (source)

Format the client's describe() output as ", k=v, k=v" for error messages. Returns an empty string when the client reports no metadata or describe itself raises (diagnostic output must never mask the real error).

async def _gather_with_cancellation(coros: Sequence[Coroutine[Any, Any, _T]]) -> list[_T]: (source)

Run coroutines concurrently, cancelling all remaining tasks if one fails.

_T = (source)

Undocumented

Value
TypeVar('_T')