. 0h^ VdZddlmZddlmZddlmZddlmZGddeZ dS) z=Helpers for batch requests to the Google Cloud Firestore API.) annotations)gapic_v1)retry)BaseWriteBatchcReZdZdZdfd Zejjdfdd Zd Z d Z xZ S) WriteBatcha Accumulate write operations to be sent in a batch. Use this over `BulkWriteBatch` for lower volumes or when the order of operations within a given batch is important. This has the same set of methods for write operations that :class:`~google.cloud.firestore_v1.document.DocumentReference` does, e.g. :meth:`~google.cloud.firestore_v1.document.DocumentReference.create`. Args: client (:class:`~google.cloud.firestore_v1.client.Client`): The client that created this batch. returnNonecZtt||dS)N)client)superr__init__)selfr __class__s Z/var/www/html/nourish/venv/lib/python3.11/site-packages/google/cloud/firestore_v1/batch.pyrzWriteBatch.__init__%s* j$(((77777Nrretries.Retry | object | Nonetimeout float | Nonelistc|||\}}|jjjd||jjd|}g|_t |jx|_}|j|_|S)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. )requestmetadata) _prep_commit_client_firestore_apicommit _rpc_metadata _write_pbsr write_results commit_time)rrrrkwargscommit_responseresultss rrzWriteBatch.commit(s&++E7;;<$,5< \/     '+O,I'J'JJW*6rc|SNr)rs r __enter__zWriteBatch.__enter__Is rc6||dSdSr')r)rexc_type exc_value tracebacks r__exit__zWriteBatch.__exit__Ls!   KKMMMMM  r)r r )rrrrr r) __name__ __module__ __qualname____doc__rrmethodDEFAULTrr(r- __classcell__)rs@rrrs  888888 08/F $BrrN) r1 __future__rgoogle.api_corerrretries$google.cloud.firestore_v1.base_batchrrrrrr9sDC""""""$$$$$$,,,,,,??????7777777777r