idZddlmZddlmZddlmZddlm Z ddl m Z m Z m Z er"ddlZddlmZdd lmZdd lmZdd lmZdd lmZGd de Zy)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)PipelineResultPipelineSnapshotPipelineStreamN)Client)Constant)PipelineExplainOptions) Transaction)ValuecpeZdZdZdfd Zdddid ddZdddid d dZxZS) 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. c&t||g|y)z Initializes a Pipeline. Args: client: The `Client` instance to use for execution. *stages: Initial stages for the pipeline. N)super__init__)selfclientstages __class__s c/var/www/html/strategist-ai/venv/lib/python3.12/site-packages/google/cloud/firestore_v1/pipeline.pyrzPipeline.__init__Bs )&)N) transaction read_timeexplain_optionsadditional_optionsctjDcic]\}}|dk7s ||}}}tt|fi|}|D cgc]} | } } t | |Scc}}wcc} w)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) r)localsitemsr rr) rrrrrkvkwargsstreamresultresultss rexecutezPipeline.executeLsh6$*8>>#3C41aqF{!Q$CC??(./f6//00D/s AA A$ctjDcic]\}}|dk7s ||}}}tt|fi|Scc}}w)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) r)rr r r)rrrrrr!r"r#s rr$zPipeline.streamlsF6$*8>>#3C41aqF{!Q$CCnd=f==Ds AA)rr rz stages.Stage) r'Transaction' | Nonerdatetime.datetime | NonerPipelineExplainOptions | Nonerdict[str, Value | Constant]returnz PipelineSnapshot[PipelineResult]) rr)rr*rr+rr,r-zPipelineStream[PipelineResult])__name__ __module__ __qualname____doc__rr'r$ __classcell__)rs@rrr*s.*-1.29=:< 1*1, 1 7 1 8 1 *1F-1.29=:< >*>, > 7 > 8 > (>rr)r1 __future__rtypingrgoogle.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.query_profiler %google.cloud.firestore_v1.transactionr (google.cloud.firestore_v1.types.documentrrrrr?sG # ?A 7GNA>^>}^>r