%9jiddlmZddlmZddlmZddlmZddl m Z m Z m Z er"ddl Z ddlmZddlmZdd lmZdd lmZdd lmZGd d eZy)) annotations) TYPE_CHECKING)pipeline_stages) _BasePipeline)PipelineResultPipelineSnapshotPipelineStreamN)Client)Constant)PipelineExplainOptions) Transaction)Valuec|eZdZUdZded<d fd Zdddid d dZdddid d dZxZS) 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 _clientc&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 ^/var/www/html/truck-me/venv/lib/python3.12/site-packages/google/cloud/firestore_v1/pipeline.pyrzPipeline.__init__=s )&)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) Raises: google.api_core.exceptions.GoogleAPIError: If there is a backend error. r)localsitemsr rr) rrrrrkvkwargsstreamresultresultss rexecutezPipeline.executeGsh<$*8>>#3C41aqF{!Q$CC??(./f6//00D/s AA A$ctjDcic]\}}|dk7s ||}}}tt|fi|Scc}}w)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. r)r r!r r)rrrrrr"r#r$s rr%zPipeline.streamjsF<$*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____annotations__rr(r% __classcell__)rs@rrr%s*O*-1.29=:< !1*!1, !1 7 !1 8 !1 *!1L-1.29=:< >*>, > 7 > 8 > (>rr) __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.documentrrrrrAsB# ?A 7GNA>d>}d>r