@@ -2734,6 +2734,17 @@ def _from_query_filter_pb(filter_pb, client):
27342734 raise TypeError (f"Unexpected filter type: { type (filter_pb )} " )
27352735
27362736
2737+ class _PipelineValueExpression (Expression ):
2738+ """Internal wrapper to represent a pipeline as an expression."""
2739+
2740+ def __init__ (self , pipeline : "_BasePipeline" ):
2741+ self .pipeline = pipeline
2742+
2743+ def _to_pb (self ) -> Value :
2744+ pipeline_pb = Pipeline_pb (stages = [s ._to_pb () for s in self .pipeline .stages ])
2745+ return Value (pipeline_value = pipeline_pb )
2746+
2747+
27372748class Array (FunctionExpression ):
27382749 """
27392750 Creates an expression that creates a Firestore array value from an input list.
@@ -2937,17 +2948,6 @@ def _to_pb(self) -> Value:
29372948 return Value (variable_reference_value = self .name )
29382949
29392950
2940- class _PipelineValueExpression (Expression ):
2941- """Internal wrapper to represent a pipeline as an expression."""
2942-
2943- def __init__ (self , pipeline : "_BasePipeline" ):
2944- self .pipeline = pipeline
2945-
2946- def _to_pb (self ) -> Value :
2947- pipeline_pb = Pipeline_pb (stages = [s ._to_pb () for s in self .pipeline .stages ])
2948- return Value (pipeline_value = pipeline_pb )
2949-
2950-
29512951class CurrentDocument (FunctionExpression ):
29522952 """
29532953 Creates an expression that represents the current document being processed.
0 commit comments