Ѯh9 NdZddlmZddlmZddlmZddlmZGddeZ y) z=Helpers for batch requests to the Google Cloud Firestore API.) annotations)gapic_v1) retry_async)BaseWriteBatchcpeZdZdZdfd Zej jdf ddZdZ dZ xZ S) AsyncWriteBatchaAccumulate write operations to be sent in a batch. This has the same set of methods for write operations that :class:`~google.cloud.firestore_v1.async_document.AsyncDocumentReference` does, e.g. :meth:`~google.cloud.firestore_v1.async_document.AsyncDocumentReference.create`. Args: client (:class:`~google.cloud.firestore_v1.async_client.AsyncClient`): The client that created this batch. c.tt| |y)N)client)superr__init__)selfr __class__s w/home/www/academy-backend.kofcorporation.com/venv/lib/python3.12/site-packages/google/cloud/firestore_v1/async_batch.pyr zAsyncWriteBatch.__init__$s ot-V-<Nc.K|j||\}}|jjjd||jjd|d{}g|_t |jx|_}|j|_|S7:w)aCommit the changes accumulated in this batch. Args: retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (float): The timeout for this request. Defaults to a system-specified value. Returns: List[:class:`google.cloud.firestore_v1.write.WriteResult`, ...]: The write results corresponding to the changes committed, returned in the same order as the changes were applied to this batch. A write result contains an ``update_time`` field. )requestmetadataN) _prep_commit_client_firestore_apicommit _rpc_metadata _write_pbslist write_results commit_time)r retrytimeoutrkwargscommit_responseresultss rrzAsyncWriteBatch.commit's&++E7; B ; ; B B! \\//! !   '+O,I,I'JJW*66 sABB;BcK|SwNr)r s r __aenter__zAsyncWriteBatch.__aenter__Hs  scFK||jd{yy7wr$)r)r exc_type exc_value tracebacks r __aexit__zAsyncWriteBatch.__aexit__Ks#  ++-    s !!)returnNone)rz"retries.AsyncRetry | object | Nonerz float | Noner+r) __name__ __module__ __qualname____doc__r rmethodDEFAULTrr%r* __classcell__)rs@rrrsK = 5=OO4K4K $1  B rrN) r0 __future__rgoogle.api_corerrretries$google.cloud.firestore_v1.base_batchrrrrrr8s#D"$2?5 n5 r