o }l~iã@s´dZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddl m Z erPdd lZdd lmZdd lmZdd lmZdd lmZddlmZGdd„de ƒZd S)z” .. warning:: **Preview API**: Firestore Pipelines is currently in preview and is subject to potential breaking changes in future releases. é)Ú annotations)Ú TYPE_CHECKING)Úpipeline_stages)Ú _BasePipeline)ÚPipelineStream)ÚPipelineSnapshot)ÚPipelineResultN)ÚClient)ÚConstant)Ú Transaction)ÚValue)ÚPipelineExplainOptionscsNeZdZdZd‡fdd„ Zdddid œddd„Zdddid œddd„Z‡ZS)ÚPipelineam 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. .. warning:: **Preview API**: Firestore Pipelines is currently in preview and is subject to potential breaking changes in future releases. Úclientr Ústagesú stages.Stagecstƒj|g|¢RŽdS)z® Initializes a Pipeline. Args: client: The `Client` instance to use for execution. *stages: Initial stages for the pipeline. N)ÚsuperÚ__init__)Úselfrr©Ú __class__©úi/var/www/newdalilibackend/backend/venv/lib/python3.10/site-packages/google/cloud/firestore_v1/pipeline.pyr=szPipeline.__init__N)Ú transactionÚ read_timeÚexplain_optionsÚadditional_optionsrú'Transaction' | Nonerúdatetime.datetime | NonerúPipelineExplainOptions | Nonerúdict[str, Value | Constant]Úreturnú PipelineSnapshot[PipelineResult]cCs>dd„tƒ ¡Dƒ}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) cSói|] \}}|dkr||“qS©rr©Ú.0ÚkÚvrrrÚ bóz$Pipeline.execute..cSsg|]}|‘qSrr)r&ÚresultrrrÚ dsz$Pipeline.execute..)ÚlocalsÚitemsrrr)rrrrrÚkwargsÚstreamÚresultsrrrÚexecuteGs zPipeline.executeúPipelineStream[PipelineResult]cCs&dd„tƒ ¡Dƒ}tt|fi|¤ŽS)aA 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) cSr#r$rr%rrrr)‚r*z#Pipeline.stream..)r-r.rr)rrrrrr/rrrr0gszPipeline.stream)rr rr) rrrrrrrr r!r") rrrrrrrr r!r3)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr2r0Ú __classcell__rrrrr%s ú#úr)r7Ú __future__rÚtypingrÚgoogle.cloud.firestore_v1rrÚ'google.cloud.firestore_v1.base_pipelinerÚ)google.cloud.firestore_v1.pipeline_resultrrrÚdatetimeÚ google.cloud.firestore_v1.clientr Ú.google.cloud.firestore_v1.pipeline_expressionsr Ú%google.cloud.firestore_v1.transactionr Ú(google.cloud.firestore_v1.types.documentr Ú'google.cloud.firestore_v1.query_profiler rrrrrÚs