temporalio.contrib.google_genai._temporal_file_search_stores.TemporalAsyncFileSearchStores

class documentation

class TemporalAsyncFileSearchStores(AsyncFileSearchStores): (source)

Constructor: TemporalAsyncFileSearchStores(api_client, activity_config)

View In Hierarchy

AsyncFileSearchStores subclass that routes upload_to_file_search_store through an activity.

The entire upload operation — including filesystem access, resumable upload negotiation, and chunked transfer — runs inside a Temporal activity on the worker. All other methods (create, get, delete, list, import_file, documents) are inherited and already work through the _TemporalApiClient's async_request activity.

Method __init__ Initialize with activity config for upload timeouts.
Async Method upload_to_file_search_store Upload a file to a file search store via a Temporal activity.
Instance Variable _activity_config Undocumented
def __init__(self, api_client: _TemporalApiClient, activity_config: ActivityConfig | None = None): (source)

Initialize with activity config for upload timeouts.

async def upload_to_file_search_store(self, *, file_search_store_name: str, file: str | os.PathLike[str] | io.IOBase, config: types.UploadToFileSearchStoreConfigOrDict | None = None) -> types.UploadToFileSearchStoreOperation: (source)

Upload a file to a file search store via a Temporal activity.

Accepts a file path (resolved on the worker), os.PathLike, or an io.IOBase (bytes sent across the activity boundary).

_activity_config = (source)

Undocumented