VSfnjdZddlmZddlmZddlmZddlmZm Z m Z ddl m Z m Z mZGddeZy ) aqClasses for representing Async aggregation queries for the Google Cloud Firestore API. A :class:`~google.cloud.firestore_v1.async_aggregation.AsyncAggregationQuery` can be created directly from a :class:`~google.cloud.firestore_v1.async_collection.AsyncCollection` and that can be a more common way to create an aggregation query than direct usage of the constructor. ) annotations)gapic_v1) retry_async)ListUnionAsyncGenerator)AggregationResult_query_response_to_resultBaseAggregationQueryceZdZdZ dfd Zdej jdf ddZdej jdf ddZ xZ S) AsyncAggregationQueryz5Represents an aggregation query to the Firestore API.c,tt| |y)N)superr __init__)self nested_query __class__s jC:\Users\user\Documents\project_loop\venv\Lib\site-packages\google/cloud/firestore_v1/async_aggregation.pyrzAsyncAggregationQuery.__init__'s #T3LANcnK|j|||}|2cgc3d{}| 76}}|Scc}ww)aRuns the aggregation query. This sends a ``RunAggregationQuery`` RPC and returns a list of aggregation results in the stream of ``RunAggregationQueryResponse`` messages. Args: transaction (Optional[:class:`~google.cloud.firestore_v1.transaction.Transaction`]): An existing transaction that this query will run in. If a ``transaction`` is used and it already has write operations added, this method cannot be used (i.e. read-after-write is not allowed). 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: The aggregation query results ) transactionretrytimeoutN)stream)rrrr stream_result aggregationresults rgetzAsyncAggregationQuery.get-sJ8 #5'$ 8EEE +EEE Fs$50+) +0+0 5cK|j|||\}}|jjjd||jjd|d{}|23d{}t |}|7 76yw)aRuns the aggregation query. This sends a ``RunAggregationQuery`` RPC and then returns an iterator which consumes each document returned in the stream of ``RunAggregationQueryResponse`` messages. If a ``transaction`` is used and it already has write operations added, this method cannot be used (i.e. read-after-write is not allowed). Args: transaction (Optional[:class:`~google.cloud.firestore_v1.transaction.Transaction`]): An existing transaction that this query will run in. 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. Yields: :class:`~google.cloud.firestore_v1.base_aggregation.AggregationResult`: The result of aggregations of this query )requestmetadataN) _prep_stream_client_firestore_apirun_aggregation_query _rpc_metadatar ) rrrrr kwargsresponse_iteratorresponsers rrzAsyncAggregationQuery.streamOs>++     #T$,,"="="S"S# \\//# #   0  (.x8FL  /s6ABA:B A>$A<%A>(B<A>>B)returnNone)r?Union[retries.AsyncRetry, None, gapic_v1.method._MethodDefault]r float | Noner+zList[AggregationResult])rr-rr.r+z4Union[AsyncGenerator[List[AggregationResult], None]]) __name__ __module__ __qualname____doc__rrmethodDEFAULTrr __classcell__)rs@rr r $s?B B OO # # $      ! H OO # # $ - -  - >-rr N)r2 __future__rgoogle.api_corerrretriestypingrrr*google.cloud.firestore_v1.base_aggregationr r r r r"rrr;s4 #$2..X0Xr