temporalio.contrib.gcp.gcsdriver._driver

module documentation
(source)

Google Cloud 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.
Function _percent_encode Percent-encode a segment of a GCS object name.
Constant _GCS_UNSAFE_CHARS Undocumented
Type Variable _T Undocumented
def _format_client_context(client: GCSStorageDriverClient) -> 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.

def _percent_encode(val: str | None) -> str | None: (source)

Percent-encode a segment of a GCS object name.

Escape characters that interfere with GCS tooling, path separators, and percent signs, preserving readable Unicode. Returns None for empty or missing values so callers can substitute "null".

_GCS_UNSAFE_CHARS = (source)

Undocumented

Value
frozenset('#[]*?:"<>|/%')
_T = (source)

Undocumented

Value
TypeVar('_T')