+ 4O|j<&DRt^RIHt^RIHtHtHt^RIHtH t H t H t ^RI H t ^RIHt^RIHt^RIHtHt]'d3^RIHt^R IHt^R IHt^R IHt^R IHt^R IH t ^RIH!t!^RI"H#t#H$t$Rt%!RR4t&!RR]&4t'!RR]'4t(!RR]&4t)R#)z;Perform aggregation operations on a collection or database.) annotations)CallableMappingMutableMapping) TYPE_CHECKINGAnyOptionalUnion)common)validate_collation_or_none)ConfigurationError)ReadPreference _AggWritePref)AsyncClientSession)AsyncCollection)AsyncCommandCursor) AsyncDatabase)AsyncConnection)Server) _ServerMode) _DocumentType _PipelineFc]tRt^'tRtRRRllt]RRl4t]RRl4tR R lt ]R R l4t R Rlt RRlt Rt R#)_AggregationCommandaThe internal abstract base class for aggregation cursors. Should not be called directly by application developers. Use :meth:`pymongo.asynchronous.collection.AsyncCollection.aggregate`, or :meth:`pymongo.asynchronous.database.AsyncDatabase.aggregate` instead. Nc<V^8dQhRRRRRRRRR R R R R RRRRR/ #)targetz/Union[AsyncDatabase[Any], AsyncCollection[Any]] cursor_classztype[AsyncCommandCursor[Any]]pipelineroptionszMutableMapping[str, Any]letzOptional[Mapping[str, Any]] user_fieldsz"Optional[MutableMapping[str, Any]]result_processorz>Optional[Callable[[Mapping[str, Any], AsyncConnection], None]]commentrreturnNone)formats"YC:\Users\alokc\chatbot\backend\venv\Lib\site-packages\pymongo/asynchronous/aggregation.py __annotate__ _AggregationCommand.__annotate__/se5?5??5?45? 5? * 5? ) 5?85?Y5?5? 5?c  RV9d \R4hWn\P!RV4pW0nRVnV'd$RVR,9gRVR,9dRVn\P !RV4Ve\P !R V4WTR &VeWR &W@n\P!R VPPR R44Vn VPPR /4VPe3VP 'g!VPVPR ,R &W n W`n Wpn\VPR R44VnVPRR4VnRVnR#)explainzGThe explain option is not supported. Use AsyncDatabase.command instead.rFz$outz$mergeTrNr r# batchSizecursor collationmaxAwaitTimeMS)r _targetr validate_list _pipeline_performs_writevalidate_is_mapping_options%validate_non_negative_integer_or_nonepop _batch_size setdefault _cursor_class _user_fields_result_processorr _collation_max_await_time_ms_write_preference) selfrrrrr r!r"r#s &&&&&&&&&r(__init___AggregationCommand.__init__/sZ  $Y  '' H=!$ 8B</8x|3K#'D ""9g6 ?  & &uc 2 EN  !(I  "GG **;=    2.    '0D0D0D373C3CDMM( #K 0)'!14W[[d5ST")++.>"E:>r+cV^8dQhRR/#)rr$zUnion[str, int]r&)r's"r(r)r*gs""_"r+c \h)z.The argument to pass to the aggregate command.NotImplementedErrorrCs&r(_aggregation_target'_AggregationCommand._aggregation_targetf "!r+cV^8dQhRR/#rr$strr&)r's"r(r)r*ls""3"r+c \h)z4The namespace in which the aggregate command is run.rHrJs&r(_cursor_namespace%_AggregationCommand._cursor_namespacekrMr+c V^8dQhRRRR/#)r cursor_docMapping[str, Any]r$AsyncCollection[Any]r&)r's"r(r)r*ps""->"CW"r+c \h:The AsyncCollection used for the aggregate command cursor.rH)rCrUs&&r(_cursor_collection&_AggregationCommand._cursor_collectionps!!r+cV^8dQhRR/#rr$AsyncDatabase[Any]r&)r's"r(r)r*us""-"r+c \h)z:The database against which the aggregation command is run.rHrJs&r( _database_AggregationCommand._databasetrMr+c V^8dQhRRRR/#)rsessionOptional[AsyncClientSession]r$z!Union[_AggWritePref, _ServerMode]r&)r's"r(r)r*ys3 *r+c VP'd VP#VPPV4pVP'd(V\P 8wd\ V4;VnpV#N)rBr3_read_preference_forr6r PRIMARYr)rCrdprefs&& r(get_read_preference'_AggregationCommand.get_read_preferenceys`  ! ! !)) )||009    DN,B,B$B,9$,? ?D "T r+c ,V^8dQhRRRRRRRRR R /#) rrdreserverrconnrread_preferencerr$z!AsyncCommandCursor[_DocumentType]r&)r's"r(r)r*sCFF-FF F % F + Fr+c "RVPRVP/pVPVP4RV9d;VP'dVP ^8dVP PpMRpRV9d/VP'dVP PV4pMRpVPVPPVVVP PRVVVPVVPPVPR7 GRjxL pVP 'dVP!W4RV9d VR,p M"R^R VP#R .4R VP$/p TP'VP)V 4T VP*VP,;'g^VP.VVPP#R 4R 7p V P1V4GRjxL V #LL5i) aggregater readConcernN writeConcernT)parse_write_concern_error read_concern write_concernr0rdclientr!r/id firstBatchresultnsr#) batch_sizemax_await_time_msrdr#)rKr5updater8r6max_wire_versionr3rv_write_concern_forcommandraname codec_optionsr@rxr>r?getrRr=r[addressr;rA_maybe_pin_connection) rCrdrnrorpcmdrvrwr{r/ cmd_cursors &&&&& r( get_cursor_AggregationCommand.get_cursorsD44j$..Q 4==!  $$$$)>)>!)C<<44LL  $)=)=)= LL;;GDM M|| NN     LL & &&*%'oo>>(())$     ! ! !  " "6 0 v H%Fafjj26d,,F''  # #F +  LL'',,1"55MM%%i0( ..t444O  L 5s@AHAHB H!G?"H8A=H6AH8H9HH) r;r@r=rAr8r6r5r?r3r>rB)NNNN)__name__ __module__ __qualname____firstlineno____doc__rDpropertyrKrRr[rarkr__static_attributes__r&r+r(rr's_5?n"""""""FFr+rcp]tRt^t$R]R&]RRl4t]RRl4tRRlt]R R l4t R t R #) _CollectionAggregationCommandrWr3cV^8dQhRR/#rOr&)r's"r(r)*_CollectionAggregationCommand.__annotate__s!!S!r+c .VPP#rgr3rrJs&r(rK1_CollectionAggregationCommand._aggregation_targets||   r+cV^8dQhRR/#rOr&)r's"r(r)rs&&3&r+c .VPP#rg)r3 full_namerJs&r(rR/_CollectionAggregationCommand._cursor_namespaces||%%%r+c V^8dQhRRRR/#rr/rVr$rWr&)r's"r(r)rs):?Sr+c VP#rYr3)rCr/s&&r(r[0_CollectionAggregationCommand._cursor_collection ||r+cV^8dQhRR/#r^r&)r's"r(r)rs%%-%r+c .VPP#rg)r3databaserJs&r(ra'_CollectionAggregationCommand._databases||$$$r+r&N) rrrr__annotations__rrKrRr[rarr&r+r(rrsG !! !!&&%%r+rc.a]tRt^tRV3RlltRtV;t#) _CollectionRawAggregationCommandc$V^8dQhRRRRRR/#)rargsrkwargsr$r%r&)r's"r(r)-_CollectionRawAggregationCommand.__annotate__s!55c5S5T5r+c |<\SV`!V/VBVP'g^VPR,R&R#R#)r/r.N)superrDr6r8)rCrr __class__s&*,r(rD)_CollectionRawAggregationCommand.__init__s; $)&)###34DMM( #K 0$r+r&)rrrrrDr __classcell__)rs@r(rrs 55r+rcp]tRt^t$R]R&]RRl4t]RRl4t]RRl4tR R lt R t R #) _DatabaseAggregationCommandr_r3cV^8dQhRR/#)rr$intr&)r's"r(r)(_DatabaseAggregationCommand.__annotate__sSr+c ^#)r&rJs&r(rK/_DatabaseAggregationCommand._aggregation_targetsr+cV^8dQhRR/#rOr&)r's"r(r)rs5535r+c 4VPP R2#)z.$cmd.aggregaterrJs&r(rR-_DatabaseAggregationCommand._cursor_namespaces,,##$O44r+cV^8dQhRR/#r^r&)r's"r(r)rs-r+c VP#rgrrJs&r(ra%_DatabaseAggregationCommand._databaserr+c V^8dQhRRRR/#rr&)r's"r(r)rs(():(?S(r+c VPRVP4PR^4wr#VPV,#)rZr|.)rrRsplitra)rCr/_collnames&& r(r[._DatabaseAggregationCommand._cursor_collections8 jjt'='=>DDS!L ~~h''r+r&N) rrrrrrrKrRrar[rr&r+r(rrsL  55((r+rN)*r __future__rcollections.abcrrrtypingrrrr pymongor pymongo.collationr pymongo.errorsr pymongo.read_preferencesr r#pymongo.asynchronous.client_sessionrpymongo.asynchronous.collectionr#pymongo.asynchronous.command_cursorrpymongo.asynchronous.databaserpymongo.asynchronous.poolrpymongo.asynchronous.serverrrpymongo.typingsrr_IS_SYNCrrrrr&r+r(rszB"==668-BF?F;9248 bbJ%$7%(5'D5("5(r+