temporalio.converter._extstore

module documentation
(source)

External payload storage support for offloading payloads to external storage systems.

Class StorageOperationMetrics Accumulates metrics from external storage operations.
Class _StorageReference Undocumented
Async Function _gather_cancel_on_error Run coroutines concurrently; cancel all remaining tasks if any one fails.
Constant _REFERENCE_ENCODING Undocumented
Type Variable _T Undocumented
Variable _current_storage_metrics Undocumented
async def _gather_cancel_on_error(coros: Sequence[Coroutine[Any, Any, _T]]) -> list[_T]: (source)

Run coroutines concurrently; cancel all remaining tasks if any one fails.

_REFERENCE_ENCODING: bytes = (source)

Undocumented

Value
b'json/external-storage-reference'
_T = (source)

Undocumented

Value
TypeVar('_T')
_current_storage_metrics: contextvars.ContextVar[StorageOperationMetrics | None] = (source)

Undocumented