o ,= ji@sddlmZddlmZddlmZddlmZddl m Z m Z m Z erFddl Z ddlmZddlmZdd lmZdd lmZdd lmZGd d d eZdS)) annotations) TYPE_CHECKING)pipeline_stages) _BasePipeline)PipelineResultPipelineSnapshotPipelineStreamN)Client)Constant)PipelineExplainOptions) Transaction)ValuecsXeZdZUdZded<dfdd Zd d d id dddZd d d id dddZZS)Pipelinea Pipelines allow for complex data transformations and queries involving multiple stages like filtering, projection, aggregation, and vector search. Usage Example: >>> from google.cloud.firestore_v1.pipeline_expressions import Field >>> >>> def run_pipeline(): ... client = Client(...) ... pipeline = client.pipeline() ... .collection("books") ... .where(Field.of("published").gt(1980)) ... .select("title", "author") ... for result in pipeline.execute(): ... print(result) Use `client.pipeline()` to create instances of this class. r Z_clientclientstages stages.Stagecstj|g|RdS)z Initializes a Pipeline. Args: client: The `Client` instance to use for execution. *stages: Initial stages for the pipeline. N)super__init__)selfrr __class__lC:\Users\psant\Downloads\Anu Raj Backend\school\venv\Lib\site-packages\google/cloud/firestore_v1/pipeline.pyr=szPipeline.__init__N) transaction read_timeexplain_optionsadditional_optionsr'Transaction' | Nonerdatetime.datetime | NonerPipelineExplainOptions | Nonerdict[str, Value | Constant]return PipelineSnapshot[PipelineResult]cCs>ddtD}tt|fi|}dd|D}t||S)a Executes this pipeline and returns results as a list 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). read_time (Optional[datetime.datetime]): If set, reads documents as they were at the given time. This must be a microsecond precision timestamp within the past one hour, or if Point-in-Time Recovery is enabled, can additionally be a whole minute timestamp within the past 7 days. For the most accurate results, use UTC timezone. explain_options (Optional[:class:`~google.cloud.firestore_v1.query_profile.PipelineExplainOptions`]): Options to enable query profiling for this query. When set, explain_metrics will be available on the returned list. additional_options (Optional[dict[str, Value | Constant]]): Additional options to pass to the query. These options will take precedence over method argument if there is a conflict (e.g. explain_options) Raises: google.api_core.exceptions.GoogleAPIError: If there is a backend error. cSi|] \}}|dkr||qSrr.0kvrrr ez$Pipeline.execute..cSsg|]}|qSrr)r&resultrrr gsz$Pipeline.execute..N)localsitemsrrr)rrrrrkwargsstreamresultsrrrexecuteGs zPipeline.executePipelineStream[PipelineResult]cCs&ddtD}tt|fi|S)a Process this pipeline as a stream, providing results through an Iterable 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). read_time (Optional[datetime.datetime]): If set, reads documents as they were at the given time. This must be a microsecond precision timestamp within the past one hour, or if Point-in-Time Recovery is enabled, can additionally be a whole minute timestamp within the past 7 days. For the most accurate results, use UTC timezone. explain_options (Optional[:class:`~google.cloud.firestore_v1.query_profile.PipelineExplainOptions`]): Options to enable query profiling for this query. When set, explain_metrics will be available on the returned generator. additional_options (Optional[dict[str, Value | Constant]]): Additional options to pass to the query. These options will take precedence over method argument if there is a conflict (e.g. explain_options) Raises: google.api_core.exceptions.GoogleAPIError: If there is a backend error. cSr#r$rr%rrrr)r*z#Pipeline.stream..N)r-r.rr)rrrrrr/rrrr0jszPipeline.stream)rr rr) rrrrrrrr r!r") rrrrrrrr r!r3) __name__ __module__ __qualname____doc____annotations__rr2r0 __classcell__rrrrr%s  &r) __future__rtypingrZgoogle.cloud.firestore_v1rrZ'google.cloud.firestore_v1.base_pipelinerZ)google.cloud.firestore_v1.pipeline_resultrrrdatetimeZ google.cloud.firestore_v1.clientr Z.google.cloud.firestore_v1.pipeline_expressionsr Z'google.cloud.firestore_v1.query_profiler Z%google.cloud.firestore_v1.transactionr Z(google.cloud.firestore_v1.types.documentr rrrrrs