§ . 0h¿%ãó—dZddlmZddlmZmZmZmZmZm Z ddl m Z m Z ddl m ZddlmZmZmZddlmZddlmZerdd lmZdd lmZdd lmZGd „d e¦«ZdS)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_CHECKINGÚAnyÚ GeneratorÚListÚOptionalÚUnion)Ú exceptionsÚgapic_v1)Úretry)ÚAggregationResultÚBaseAggregationQueryÚ_query_response_to_result)ÚQueryResultsList)ÚStreamGenerator)Ú transaction)ÚExplainMetrics)ÚExplainOptionsc󬇗eZdZdZdˆfd„ Zdejjdfddœdd„Zdd„Z d„Z dejjddfdd„Z dejjdfddœdd„Z ˆxZ S)ÚAggregationQueryz5Represents an aggregation query to the Firestore API.ÚreturnÚNonecóX•—tt|¦« |¦«dS©N)ÚsuperrÚ__init__)ÚselfÚ nested_queryÚ __class__s €ú`/var/www/html/nourish/venv/lib/python3.11/site-packages/google/cloud/firestore_v1/aggregation.pyrzAggregationQuery.__init__.s*ø€õ Õ Ñ%Ô%×.Ò.¨|Ñ<Ô<Ð<Ð<Ð<óN)Úexplain_optionsr ú"Union[retries.Retry, None, object]Útimeoutú float | Noner"úOptional[ExplainOptions]ú#QueryResultsList[AggregationResult]cóª—d}| ||||¬¦«}t|¦«}|€d}n| ¦«}t|||¦«S)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. N©rr r$r")ÚstreamÚlistÚget_explain_metricsr)rrr r$r"Úexplain_metricsÚresultÚ result_lists r ÚgetzAggregationQuery.get4sk€ðD26ˆà—’Ø#ØØØ+ð ñ ô ˆõ ˜6‘l”lˆ à Ð "Ø"ˆOˆOà$×8Ò8Ñ:Ô:ˆOå  ¨_¸oÑNÔNÐNr!có€—| ||||¦«\}}|jjjd||jjdœ|¤ŽS)ú!Helper method for :meth:`stream`.)ÚrequestÚmetadata©)Ú _prep_streamÚ_clientÚ_firestore_apiÚrun_aggregation_queryÚ _rpc_metadata)rrr r$r"r3Úkwargss r Ú_get_stream_iteratorz%AggregationQuery._get_stream_iteratorgse€à×+Ò+Ø Ø Ø Ø ñ  ô ‰ˆðAˆtŒ|Ô*Ô@ð ØØ”\Ô/ð ð ðð ð ð r!có˜—|€G|tjjur|jjj}|j}|j}| |¦«SdS)r2NF) r ÚmethodÚDEFAULTr7r8Ú _transportr9Ú_retryÚ _predicate)rÚexcr rÚ transportÚgapic_callables r Ú_retry_query_after_exceptionz-AggregationQuery._retry_query_after_exceptionvsN€à Ð ØœÔ/Ð/Ð/Ø œLÔ7ÔB Ø!*Ô!@Ø&Ô-Ø×#Ò# CÑ(Ô(Ð (àˆur!rú!Optional[transaction.Transaction]úOptional[float]úAGenerator[List[AggregationResult], Any, Optional[ExplainMetrics]]c#óLK—d}| ||||¦«} t|d¦«}nK#tj$r9}| |||¦«r| |||¦«}Yd}~ŒU‚d}~wwxYw|€n&|€|jr|j}t |¦«} | r| V—Œ†|S)aÌInternal 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)r<Únextr ÚGoogleAPICallErrorrFr-r) rrr r$r"ÚmetricsÚresponse_iteratorÚresponserCr.s r Ú _make_streamzAggregationQuery._make_streamsèè€ðN*.ˆà ×5Ò5Ø Ø Ø Ø ñ  ô Ðð  ð ÝÐ 1°4Ñ8Ô8øÝÔ0ð ð ð Ø×4Ò4°S¸%ÀÑMÔMðØ(,×(AÒ(AØ#ØØñ)ô)Ð%ð HHHHàøøøøð øøøðÐØàˆ 8Ô#;ˆØ"Ô2å.¨xÑ8Ô8ˆFØð Ø ð- ð0ˆsŸ0°A8¿.A3Á2A3Á3A8ú#Optional['transaction.Transaction']ú(StreamGenerator[List[AggregationResult]]cóT—| ||||¬¦«}t||¦«S)aRuns 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))rPr)rrr r$r"Úinner_generators r r*zAggregationQuery.streamÊs=€ðF×+Ò+Ø#ØØØ+ð ,ñ ô ˆõ ˜°Ñ@Ô@Ð@r!)rr)r r#r$r%r"r&rr'r) rrGr r#r$rHr"r&rrI) rrQr r#r$rHr"r&rrR)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr r>r?r0r<rFrPr*Ú __classcell__)rs@r rr+sø€€€€€Ø?Ð?ð=ð=ð=ð=ð=ð=ðØ4<´OÔ4KØ $ð 1Oð 59ð 1Oð1Oð1Oð1Oð1Oð1Oðf  ð  ð  ð  ð ð ð ð:>Ø4<´OÔ4KØ#'Ø48ð GðGðGðGðGðV<@Ø4<´OÔ4KØ#'ð )Að 59ð )Að)Að)Að)Að)Að)Að)Að)Að)Að)Ar!rN)rXÚ __future__rÚtypingrrrrrr Úgoogle.api_corer r r ÚretriesÚ*google.cloud.firestore_v1.base_aggregationr rrÚ'google.cloud.firestore_v1.query_resultsrÚ*google.cloud.firestore_v1.stream_generatorrÚgoogle.cloud.firestore_v1rÚ'google.cloud.firestore_v1.query_profilerrrr5r!r úrcs`ðððð #Ð"Ð"Ð"Ð"Ð"àGÐGÐGÐGÐGÐGÐGÐGÐGÐGÐGÐGÐGÐGÐGÐGà0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ø,Ð,Ð,Ð,Ð,Ð,ððððððððððð EÐDÐDÐDÐDÐDØFÐFÐFÐFÐFÐFððGØ5Ð5Ð5Ð5Ð5Ð5ØFÐFÐFÐFÐFÐFØFÐFÐFÐFÐFÐFðHAðHAðHAðHAðHAÐ+ñHAôHAðHAðHAðHAr!