U $FZh^ @sHdZddlmZddlmZddlmZddlmZGdddeZ dS) z=Helpers for batch requests to the Google Cloud Firestore API.) annotations)gapic_v1)retry)BaseWriteBatchcsReZdZdZddfdd Zejjdfddd d d d Zd dZ ddZ Z 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. None)returncstt|j|ddS)N)client)superr__init__)selfr  __class__f/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/google/cloud/firestore_v1/batch.pyr %szWriteBatch.__init__Nzretries.Retry | object | Nonez float | Nonelist)rtimeoutrcCsP|||\}}|jjjf||jjd|}g|_t|j|_}|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) Z _prep_commitZ_clientZ_firestore_apicommitZ _rpc_metadataZ _write_pbsrZ write_resultsZ commit_time)r rrrkwargsZcommit_responseresultsrrrr(s zWriteBatch.commitcCs|SNr)r rrr __enter__IszWriteBatch.__enter__cCs|dkr|dSr)r)r exc_type exc_value tracebackrrr__exit__LszWriteBatch.__exit__) __name__ __module__ __qualname____doc__r rmethodDEFAULTrrr __classcell__rrr rrs !rN) r! __future__rZgoogle.api_corerrretriesZ$google.cloud.firestore_v1.base_batchrrrrrrs