(ph%SrSSKJr SSKJrJrJrJrJrJ r SSK J r J r SSK J r SSKJrJrJr SSKJr SSKJr \(aSS KJr SS KJr SS KJr "S S \5rg)aUClasses for representing aggregation queries for the Google Cloud Firestore API. A :class:`~google.cloud.firestore_v1.aggregation.AggregationQuery` can be created directly from a :class:`~google.cloud.firestore_v1.collection.Collection` and that can be a more common way to create an aggregation query than direct usage of the constructor. ) annotations) TYPE_CHECKINGAny GeneratorListOptionalUnion) exceptionsgapic_v1)retry)AggregationResultBaseAggregationQuery_query_response_to_result)QueryResultsList)StreamGenerator) transaction)ExplainMetrics)ExplainOptionsc<^\rSrSrSrS U4SjjrS\RRS4SS.S Sjjjr SSjr Sr S\RRSS4SS jjr S\RRS4SS.SS jjjr S rU=r$)AggregationQuery+z5Represents an aggregation query to the Firestore API.c,>[[U] U5 gN)superr__init__)self nested_query __class__s X/var/www/html/venv/lib/python3.13/site-packages/google/cloud/firestore_v1/aggregation.pyrAggregationQuery.__init__.s .|<N)explain_optionscSnURUUUUS9n[U5nUcSnOUR5n[XtU5$)a+Runs 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. explain_options (Optional[:class:`~google.cloud.firestore_v1.query_profile.ExplainOptions`]): Options to enable query profiling for this query. When set, explain_metrics will be available on the returned generator. Returns: QueryResultsList[AggregationResult]: The aggregation query results. Nrr timeoutr")streamlistget_explain_metricsr)rrr r%r"explain_metricsresult result_lists rgetAggregationQuery.get4sZD26#+   6l  ""O$88:O oNNr!cURUUUU5upVURRR"SUURRS.UD6$)!Helper method for :meth:`stream`.)requestmetadata) _prep_stream_client_firestore_apirun_aggregation_query _rpc_metadata)rrr r%r"r0kwargss r_get_stream_iterator%AggregationQuery._get_stream_iteratorgs^++      ||**@@ \\//   r!cUcfU[RRLa8URRR nUR nURnURU5$g)r/F) r methodDEFAULTr4r5 _transportr6_retry _predicate)rexcr r transportgapic_callables r_retry_query_after_exception-AggregationQuery._retry_query_after_exceptionvsY  /// LL77BB !*!@!@&--##C( (r!c#h# SnURUUUU5n[US5nUcU$UcUR (a UR n[ U5n U (aU v MK![Ra6nUR XU5(aURUUU5nSnAMeSnAff=f7f)aInternal method for stream(). Runs the aggregation query. This sends a ``RunAggregationQuery`` RPC and then returns a generator 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 (Optional[google.api_core.retry.Retry]): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (Optional[float]): The timeout for this request. Defaults to a system-specified value. explain_options (Optional[:class:`~google.cloud.firestore_v1.query_profile.ExplainOptions`]): Options to enable query profiling for this query. When set, explain_metrics will be available on the returned generator. Yields: List[AggregationResult]: The result of aggregations of this query. Returns: (Optional[google.cloud.firestore_v1.types.query_profile.ExplainMetrtics]): The results of query profiling, if received from the service. N)r9nextr GoogleAPICallErrorrDr)r) rrr r%r"metricsresponse_iteratorresponserAr*s r _make_streamAggregationQuery._make_streamsN*. 55         1488#;#;"22.x8F -00 44SMM(,(A(A#)%  s3B2 A%>B2%B/9*B*#B2)B**B//B2c<URUUUUS9n[XT5$)aQRuns the aggregation query. This sends a ``RunAggregationQuery`` RPC and then returns a generator 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 (Optional[google.api_core.retry.Retry]): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (Optinal[float]): The timeout for this request. Defaults to a system-specified value. explain_options (Optional[:class:`~google.cloud.firestore_v1.query_profile.ExplainOptions`]): Options to enable query profiling for this query. When set, explain_metrics will be available on the returned generator. Returns: `StreamGenerator[List[AggregationResult]]`: A generator of the query results. r$)rLr)rrr r%r"inner_generators rr&AggregationQuery.streams3F++#+ ,  @@r!r2)returnNone)r "Union[retries.Retry, None, object]r%z float | Noner"Optional[ExplainOptions]rQz#QueryResultsList[AggregationResult]r) rz!Optional[transaction.Transaction]r rSr%Optional[float]r"rTrQzAGenerator[List[AggregationResult], Any, Optional[ExplainMetrics]]) rz#Optional['transaction.Transaction']r rSr%rUr"rTrQz(StreamGenerator[List[AggregationResult]])__name__ __module__ __qualname____firstlineno____doc__rr r<r=r,r9rDrLr&__static_attributes__ __classcell__)rs@rrr+s)?= =44rfsM #GG0, EF5FFHA+HAr!