+
    8ix                       R t ^ RIHt ^ RIt^ RIt^ RIt^ RIHt ^ RIH	t	 ^ RI
HtHtHtHtHtHt ^ RIHt ^ RIHt ^ RIHtHt ^ R	IHtHt ^ R
IHt ^ RIHt ^ RIH t  ^ RI!H"t" ]'       d   ^ RI#H$t$ ^ RI%H&t& ^ RI'H(t(H)t) ^ RI*H+t+H,t,H-t- ^ RI.H/t/H0t0H1t1H2t2H3t3H4t4H5t5 ^ RI6H7t7 ^ RI8H9t9H:t:H;t; ^ RI<H=t=H>t>H?t?H@t@HAtA ^ RIBHCtC ^ RIDHEtEHFtFHGtGHHtH ^ RIIHJtJHKtK ^ RILHMtM RtN ! R R4      tOR# )zIThe client-level bulk write operations interface.

.. versionadded:: 4.9
)annotationsN)MutableMapping)islice)TYPE_CHECKINGAnyMappingOptionalTypeUnion)ObjectId)RawBSONDocument)_csotcommon)ClientSession_validate_session_write_concern)
Collection)CommandCursor)Database)_handle_reauth)MongoClient)
Connection)_merge_command"_throw_client_bulk_write_exception)validate_is_document_typevalidate_ok_for_replacevalidate_ok_for_update)ConfigurationErrorConnectionFailureInvalidOperationNotPrimaryErrorOperationFailurePyMongoErrorWaitQueueTimeoutError)_RETRYABLE_ERROR_CODES)_COMMAND_LOGGER_CommandStatusMessage
_debug_log)_ClientBulkWriteContext_convert_client_bulk_exception_convert_exception_convert_write_result_randint)ReadPreference)ClientBulkWriteResultDeleteResultInsertOneResultUpdateResult)_DocumentOut	_Pipeline)WriteConcernTc                     ] tR t^WtRtR$R R llt]R R l4       tR R ltR%R	 R
 llt	R&R R llt
R'R R llt]R R l4       tR R ltR R ltR R ltR R ltR(R R lltR R ltR R ltR R  ltR! R" ltR#tR# ))_ClientBulkz4The private guts of the client-level bulk write API.Nc               8    V ^8  d   QhRRRRRRRRR	R
RRRRRR/# )   clientMongoClient[Any]write_concernr3   orderedboolbypass_document_validationOptional[bool]commentzOptional[str]letzOptional[Any]verbose_resultsreturnNone )formats   "]/var/www/html/photoedit/myenv/lib/python3.14/site-packages/pymongo/synchronous/client_bulk.py__annotate___ClientBulk.__annotate__Z   sZ     - - - $- 	-
 %3- - - - 
-    c                   Wn         W n        W`n        V P                  e"   \        P                  ! RV P                  4       W0n        W@n        WPn        Wpn        . V n	        . V n
        ^ V n        ^ V n        RV n        RV n        RV n        V P                   P                   P"                  V n        RV n        RV n        R# )z"Initialize a _ClientBulk instance.Nr@   F)r8   r:   r@   r   r   r;   bypass_doc_valr?   rA   ops
namespaces
idx_offset	total_opsexecuteduses_collationuses_array_filtersoptionsretry_writesis_retryableretryingstarted_retryable_write)selfr8   r:   r;   r=   r?   r@   rA   s   &&&&&&&&rF   __init___ClientBulk.__init__Z   s     *88,,UDHH=8.8:%' #"' KK//<<',$rI   c                   V ^8  d   QhRR/# )r7   rB   zType[_ClientBulkWriteContext]rD   )rE   s   "rF   rG   rH   z   s     ' ' = 'rI   c                	    \         # N)r'   )rX   s   &rF   bulk_ctx_class_ClientBulk.bulk_ctx_classy   s    &&rI   c               $    V ^8  d   QhRRRRRR/# )r7   	namespacestrdocumentr1   rB   rC   rD   )rE   s   "rF   rG   rH   }   s!     	 	C 	< 	D 	rI   c                    \        RV4       \        V\        4      '       g   RV9   g   \        4       VR&   RRRV/pV P                  P                  RV34       V P                  P                  V4       V ;P                  ^,          un        R# )z*Add an insert document to the list of ops.rc   _idinsertN)r   
isinstancer   r   rL   appendrM   rO   )rX   ra   rc   cmds   &&& rF   
add_insert_ClientBulk.add_insert}   sm    !*h78_55(9J&jHUOZ23(y)!rI   c               @    V ^8  d   QhRRRRRRRRR	R
RRRRRRRRRR/
# )r7   ra   rb   selectorMapping[str, Any]updatez#Union[Mapping[str, Any], _Pipeline]multir<   upsertr>   	collationOptional[Mapping[str, Any]]array_filtersz!Optional[list[Mapping[str, Any]]]hint Union[str, dict[str, Any], None]sortrB   rC   rD   )rE   s   "rF   rG   rH      sn     % %% $% 4	%
 % % /% 9% /% *% 
%rI   c
                \   \        V4       RRRVRVRV/p
Ve   WZR&   Ve   RV n        WzR&   Ve   WR	&   Ve   RV n        WjR
&   V	e   WR&   V'       d   RV n        V P                  P                  RV
34       V P                  P                  V4       V ;P                  ^,          un        R# )z8Create an update document and add it to the list of ops.rp   filter
updateModsrq   Nrr   TarrayFiltersrv   rs   rx   Frg   )r   rR   rQ   rU   rL   ri   rM   rO   )rX   ra   rn   rp   rq   rr   rs   ru   rv   rx   rj   s   &&&&&&&&&& rF   
add_update_ClientBulk.add_update   s     	v&bh&U	
 "M$&*D#"/K "&D(K %D3(y)!rI   c               8    V ^8  d   QhRRRRRRRRRR	R
RRR	RR/# )r7   ra   rb   rn   ro   replacementrr   r>   rs   rt   rv   rw   rx   rB   rC   rD   )rE   s   "rF   rG   rH      sZ       $ '	
  / / * 
rI   c                    \        V4       RRRVRVRR/pVe   WHR&   Ve   WhR&   Ve   R	V n        WXR
&   Ve   WxR&   V P                  P                  RV34       V P                  P                  V4       V ;P
                  ^,          un        R# )z8Create a replace document and add it to the list of ops.rp   rz   r{   rq   FNrr   rv   Trs   rx   replacerg   )r   rQ   rL   ri   rM   rO   )	rX   ra   rn   r   rr   rs   rv   rx   rj   s	   &&&&&&&& rF   add_replace_ClientBulk.add_replace   s     	 ,bh+U	
 "MK "&D(KC()y)!rI   c               0    V ^8  d   QhRRRRRRRRR	R
RR/# )r7   ra   rb   rn   ro   rq   r<   rs   rt   rv   rw   rB   rC   rD   )rE   s   "rF   rG   rH      sF       $ 	
 / / 
rI   c                   RR	RVRV/pVe   WVR&   Ve   RV n         WFR&   V'       d   RV n        V P                  P                  RV34       V P                  P                  V4       V ;P
                  ^,          un        R# )
z7Create a delete document and add it to the list of ops.deleterz   rq   Nrv   Trs   Frg   )rQ   rU   rL   ri   rM   rO   )rX   ra   rn   rq   rs   rv   rj   s   &&&&&& rF   
add_delete_ClientBulk.add_delete   sx     Xx%@K "&D( %D3(y)!rI   c               8    V ^8  d   QhRRRRRRRRR	R
RR
RRRR/# )r7   bwcr'   rj   MutableMapping[str, Any]
request_idintmsgzUnion[bytes, dict[str, Any]]op_docslist[Mapping[str, Any]]ns_docsr8   r9   rB   dict[str, Any]rD   )rE   s   "rF   rG   rH      sd     Y Y$Y &Y 	Y
 *Y )Y )Y !Y 
YrI   c                	   WRR&   WbR&   \         P                  ! \        P                  4      '       d   \	        \         \
        P                  VP                  P                  V\        \        V4      4      VP                  VVVP                  P                  VP                  P                  VP                  P                  ^ ,          VP                  P                  ^,          VP                  P                   R7       VP"                  '       d   VP%                  W#WV4        VP                  P'                  W4VP(                  4      p\*        P*                  P-                  4       VP.                  ,
          p	\         P                  ! \        P                  4      '       d   \	        \         \
        P0                  VP                  P                  V	V\        \        V4      4      VP                  VVVP                  P                  VP                  P                  VP                  P                  ^ ,          VP                  P                  ^,          VP                  P                   R7       VP"                  '       d   VP3                  W8V	4       V P4                  P7                  WP8                  4       V#   \:         Ed   p
\*        P*                  P-                  4       TP.                  ,
          p	\=        T
\>        \@        34      '       d   T
PB                  pM\E        T
4      p\         P                  ! \        P                  4      '       d   \	        \         \
        PF                  TP                  P                  T	T\        \        T4      4      TP                  TTTP                  P                  TP                  P                  TP                  P                  ^ ,          TP                  P                  ^,          TP                  P                   \=        T
\@        4      R7       TP"                  '       d   TPI                  Y;T	4       RT
/p\=        T
\@        4      '       d7   T P4                  P7                  T
PB                  TP8                  4        Rp
?
T# T P4                  P7                  / TP8                  4        Rp
?
T# Rp
?
ii ; i)zCA proxy for Connection.write_command that handles event publishing.rL   nsInfomessageclientIdcommandcommandNamedatabaseName	requestIdoperationIddriverConnectionIdserverConnectionId
serverHost
serverPort	serviceIdr   r   
durationMSreplyr   r   r   r   r   r   r   r   r   r   r   r   failurer   r   r   r   r   r   r   r   r   isServerSideErrorerrorN)%r$   isEnabledForloggingDEBUGr&   r%   STARTED_topology_settings_topology_idnextiterdb_nameconnidserver_connection_idaddress
service_idpublish_startwrite_commandcodecdatetimenow
start_time	SUCCEEDED_succeedr8   _process_responsesession	Exceptionrh   r   r    detailsr)   FAILED_fail)rX   r   rj   r   r   r   r   r8   r   durationexcr   s   &&&&&&&&    rF   r   _ClientBulk.write_command   sR    E
H''66-5522?? cO [[$&#&88;;#&88#@#@88++A.88++A.((-- ;;;JJs99	?HH**:CIIFE((,,.?H++GMM::#1;;#66CC' $T#Y!$( *'*xx{{'*xx'D'D"xx//2"xx//2!hh11  {{{Z9KK))%=F E  !	?((,,.?H#1ABCC(+,S1++GMM::#188#66CC'# $T#Y!$( *'*xx{{'*xx'D'D"xx//2"xx//2!hh11&06F&G$ {{{		*x8cNE#/00--ckk3;;GG  --b#++>>E!	?s4   $EJ; 7J; ;SBSC-SAS$&SSc               8    V ^8  d   QhRRRRRRRRR	R
RR
RRRR/# )r7   r   r'   rj   r   r   r   r   bytesr   r   r   r8   r9   rB   rt   rD   )rE   s   "rF   rG   rH   @  sd     W W$W &W 	W
 W )W )W !W 
%WrI   c                0	   \         P                  ! \        P                  4      '       d   \	        \         \
        P                  VP                  P                  V\        \        V4      4      VP                  VVVP                  P                  VP                  P                  VP                  P                  ^ ,          VP                  P                  ^,          VP                  P                   R7       VP"                  '       d   VP%                  W#WV4      p VP                  P'                  WAP(                  4      p\*        P*                  P-                  4       VP.                  ,
          p	Ve   \1        VP2                  W(4      p
MR^/p
\         P                  ! \        P                  4      '       d   \	        \         \
        P4                  VP                  P                  V	V
\        \        V4      4      VP                  VVVP                  P                  VP                  P                  VP                  P                  ^ ,          VP                  P                  ^,          VP                  P                   R7       VP"                  '       d   VP7                  W:V	4       V
#   \8         Ed   p\*        P*                  P-                  4       TP.                  ,
          p	\;        T\<        4      '       d"   \1        TP2                  Y+P>                  4      pM.\;        T\@        4      '       d   TP>                  pM\C        T4      p\         P                  ! \        P                  4      '       d   \	        \         \
        PD                  TP                  P                  T	T\        \        T4      4      TP                  TTTP                  P                  TP                  P                  TP                  P                  ^ ,          TP                  P                  ^,          TP                  P                   \;        T\<        4      R7       TP"                  '       d#   TP.                  f   Q hTPG                  Y<T	4       RT/p
 Rp?T
# Rp?ii ; i)zAA proxy for Connection.unack_write that handles event publishing.r   Nokr   r   r   )$r$   r   r   r   r&   r%   r   r   r   r   r   r   r   r   r   r   r   r   r   unack_writemax_bson_sizer   r   r   r*   namer   r   r   rh   r    r   r   r)   r   r   )rX   r   rj   r   r   r   r   r8   resultr   r   r   r   s   &&&&&&&&     rF   r   _ClientBulk.unack_write@  s*    ''66-5522?? cO [[$&#&88;;#&88#@#@88++A.88++A.((-- ;;;**Sg?C9	#XX))#/@/@AF((,,.?H!-chhD q	"//>>' 5 ? ?!'!:!:!G!G#+#$(cO%([[",$.+.88;;+.88+H+H#&88#3#3A#6#&88#3#3A#6"%(("5"5  {{{Z9@ ?  	#((,,.?H#/00(=chh[[(YC11++,S1++GMM::#188#66CC'# $T#Y!$( *'*xx{{'*xx'D'D"xx//2"xx//2!hh11&06F&G" {{{~~111		*x8cNE?	#s4   BJ, 9CJ, J, ,R8B=R6C-R$&RRc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r7   r   r'   rj   r   rL   #list[tuple[str, Mapping[str, Any]]]rM   	list[str]rB   z7tuple[list[Mapping[str, Any]], list[Mapping[str, Any]]]rD   )rE   s   "rF   rG   rH     s=     
' 
'$
' 
' 1	
'
 
' 
A
'rI   c           	     n    VP                  W#V4      w  rVrxV P                  WWVWxV P                  4       Wx3# )z6Executes a batch of bulkWrite server commands (unack).)batch_commandr   r8   )	rX   r   rj   rL   rM   r   r   to_send_ops
to_send_nss	   &&&&&    rF   _execute_batch_unack _ClientBulk._execute_batch_unack  s<     473D3DSz3Z0
:KT[[Y&&rI   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r7   r   r'   rj   r   rL   r   rM   r   rB   zGtuple[dict[str, Any], list[Mapping[str, Any]], list[Mapping[str, Any]]]rD   )rE   s   "rF   rG   rH     s=     
/ 
/$
/ 
/ 1	
/
 
/ 
Q
/rI   c           	     p    VP                  W#V4      w  rVrxV P                  WWVWxV P                  4      p	WV3# )z4Executes a batch of bulkWrite server commands (ack).)r   r   r8   )
rX   r   rj   rL   rM   r   r   r   r   r   s
   &&&&&     rF   _execute_batch_ClientBulk._execute_batch  sC     473D3DSz3Z0
##Cj{X\XcXcdJ..rI   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r7   full_resultr   r   r   r   r   Optional[ClientSession]rB   rC   rD   )rE   s   "rF   rG   rH     sC     2F 2F-2F )2F 	2F
 )2F 
2FrI   c                   VP                  R4      '       Edf   V'       d   RVn        \        \        V P                  R4      RR7      p\        VVR,          VP                  VV P                  R7      pVP                  V4        V F  pVR,          V P                  ,           pV P                  V,          w  rVR,          '       g.   VR	,          P                  V4       V P                  '       d    R
# VR,          '       g   K  V P                  '       g   K  V	R8X  d   V
R,          R,          p\        VRR7      pV	R9   d   Rp	\        VRRR7      pV	R8X  d   \!        VRR7      pXW R2,          V&   K  	  R
# R
#   \"         d<   pTP$                  '       d   TP'                  4        \)        T4      TR&    R
p?R
# R
p?ii ; i)z?Internal helper for processing the server reply command cursor.cursorTadminz$cmd.bulkWrite)databaser   )r   r?   idxr   writeErrorsNrf   rc   re   )acknowledgedrp   )r   in_client_bulkr   Resultsr   )rp   r   )get_leave_aliver   r   r8   r   r   r?   _maybe_pin_connectionrN   rL   ri   r;   rA   r/   r0   r.   r   alivecloser(   )rX   r   r   r   r   coll
cmd_cursordocoriginal_indexop_typeopinserted_idresr   s   &&&&&         rF   _process_results_cursor#_ClientBulk._process_results_cursor  s    ::h'+$!$++w7%D 'x J ,,T2F%C%(Z$//%AN"&((>":KGt99}-44S9<<<" 4yyT%9%9%9"h.*,Z.*?K"1+D"QC"&;;&.G".sVZ"[C"h.".s"FCKNiw$78H' &%  L  F###$$&"@"Ew	Fs2   A,F  3F  6F  F  A!F   G0GGc               8    V ^8  d   QhRRRRRRRRR	R
RRRRRR/# )r7   r:   r3   r   r   r   r   op_idr   	retryabler<   r   r   final_write_concernzOptional[WriteConcern]rB   rC   rD   )rE   s   "rF   rG   rH     sd     I I#I )I 	I
 I I .I 4I 
IrI   c           	     P   RpRp	V P                   P                  p
VP                  V P                   V4       V P                  VV	VVV
VV P                   P                  4      pV P
                  V P                  8  Ed)   V P                  V P
                  ,
          VP                  8:  d   T;'       g    TpR^/pV P                  '       * VR&   V P                  VR&   T;'       d    VP                  '       * pV'       g	   V'       g   \        P                  ! W4       V P                  e   V P                  VR&   V P                  '       d   V P                  VR&   V P                  '       d   V P                  VR&   V'       dS   V'       d*   V P                   '       g   VP#                  4        R	V n        VP%                  W\&        P(                  V4       VP+                  WV P                   4       VP-                  V4       VP/                  V P                   V4       \1        V P2                  V P
                  R4      p\1        V P4                  V P
                  R4      pVP6                  '       Ed   V P9                  WW4      w  pppTpVP;                  R
4      '       Ede   VR
,          p\=        VR4      ;'       dF    \?        VP@                  \B        4      ;'       d$    VP@                  P;                  R^ 4      \D        9   p\?        V\F        4      ;'       d    \?        V\H        \J        34      '       * p\?        V\L        4      ;'       d    VPO                  R4      pV'       dh   V'       g   V'       g	   V'       dP   \P        PR                  ! V4      p\U        V P2                  V P
                  VV4       \W        VV P                  4       M7\U        V P2                  V P
                  VV4       \W        W`P                  4       RVR
&   . VR&   VP;                  R^ 4      \Y        V4      8  d   R	VR&   VR,          '       g*   VVR
&   \U        V P2                  V P
                  VV4       R# V'       d|   VP;                  R/ 4      pVP;                  R^ 4      \D        9   dO   \P        PR                  ! V4      p\U        V P2                  V P
                  VV4       \W        VV P                  4       V P[                  VVW24       \U        V P2                  V P
                  VV4       RV n.        RV n        MV P_                  WW4      w  ppV ;P
                  \Y        V4      ,          un        VR
,          '       g(   V P                  '       g   EK0  VR,          '       g   EKB  R# R# )z<Internal helper for executing batches of bulkWrite commands.r   	bulkWrite
errorsOnlyr;   NbypassDocumentValidationr?   r@   Tr   r   codeRetryableErrorr   nErrorsanySuccessfulr   writeConcernErrorF)0r8   _event_listenersvalidate_sessionr^   codec_optionsrN   rO   max_write_batch_sizerA   r;   in_transactionr   apply_write_concernrK   r?   r@   rW   _start_retryable_write	_apply_tor,   PRIMARYsend_cluster_timeadd_server_apiapply_timeoutr   rL   rM   r   r   r   hasattrrh   r   dictr#   r   r   r"   r!   has_error_labelcopydeepcopyr   r   lenr   rV   r   )rX   r:   r   r   r   r   r   r   r   cmd_name	listenersr   rj   not_in_transactionrL   rM   
raw_resultr   _r   r   retryable_top_level_errorretryable_network_errorretryable_label_errorfullwces   &&&&&&&&                  rF   _execute_command_ClientBulk._execute_command  s    KK00	 	dkk73!!KK%%
 oo. ~~/33K3KK 3 D D} "C$($8$8 8C!\\C	N!(!G!G1G1G-G!))#="".262E2E./|||!%Ixxx!XXE
 T%A%A%A22437D0!!#.2H2H$O""3=$t{{C04??D9C$GJ )))-1-@-@3-[*
K# ::g&&"7OEy1 S S&u}}d;S S!MM--fa8<RR .
 /90/ /Z /Z(BW0XYY , -7|- -B -B//0@A * !120#}}[9&txx$O:4AUAUV&txx+vV:;H\H\]"&w(*}%::i+c+.>>37K0 d||&0F7O"488T__k6R **%8"=Cwwvq)-CC  $}}[9&txx$O:4AUAUV ,,[&$P txx+vN !&/4, "&!:!:3S!UQOOs;//O 7##]9S9SY /rI   c               $    V ^8  d   QhRRRRRR/# )r7   r   r   	operationrb   rB   r   rD   )rE   s   "rF   rG   rH   p  s(     3 3(3 3 
"	3rI   c                F  a aa RRRRR. R. R^ R^ R	^ R
^ R^ R/ R/ R/ /o\        4       oR VVV 3R llpS P                  P                  S P                  VVVS SR7       SR,          '       g   SR,          '       g   SR,          '       d   \	        SS P
                  4       S# )z'Execute commands with w=1 WriteConcern.r  Fr   Nr   writeConcernErrors	nInserted	nUpsertednMatched	nModifiednDeletedinsertResultsupdateResultsdeleteResultsc               (    V ^8  d   QhRRRRRRRR/# )	r7   r   r   r   r   r   r<   rB   rC   rD   )rE   s   "rF   rG   1_ClientBulk.execute_command.<locals>.__annotate__  s0     	 	,		 	 		rI   c                   < VP                   ^8  d   \        R4      hSP                  SP                  V VSVS4       R# )   <MongoClient.bulk_write requires MongoDB server version 8.0+.N)max_wire_versionr   r$  r:   )r   r   r   r   r   rX   s   &&&rF   retryable_bulk3_ClientBulk.execute_command.<locals>.retryable_bulk  sK    
 $$r)&R  !!""rI   )bulkoperation_id)r+   r8   _retryable_writerU   r   rA   )rX   r   r'  r8  r   r   s   f&& @@rF   execute_command_ClientBulk.execute_commandp  s     UT2 "RRR1
 
	 	$ 	$$ 	% 	
 w;}#=#=MaAbAb.{D<P<PQrI   c                    V ^8  d   QhRRRR/# r7   r   r   rB   rC   rD   )rE   s   "rF   rG   rH     s     (0 (0(0 
(0rI   c           	        RpRpV P                   P                  p\        4       pV P                  VVVVVRV P                   P                  4      pV P
                  V P                  8  Ed   R^/pRVR&   RVR&   V P                  e   V P                  VR&   R	^ /VR
&   V P                  '       d   V P                  VR&   V P                  '       d   V P                  VR&   VP                  V4       \        V P                  V P
                  R4      p\        V P                  V P
                  R4      p	V P                  WgW4      w  rV ;P
                  \        V
4      ,          un        EK  R# )zDExecute commands with OP_MSG and w=0 writeConcern. Always unordered.r   r   NTr  Fr;   r  wwriteConcernr?   r@   )r8   r  r+   r^   r
  rN   rO   rK   r?   r@   r  r   rL   rM   r   r  )rX   r   r   r  r  r   r   rj   rL   rM   r   r  s   &&          rF   execute_command_unack!_ClientBulk.execute_command_unack  sC   
 KK00	
!!KK%%
 oo."C $C"C	N"".262E2E./#&(C|||!%Ixxx!XXE
$4??D9C$GJ "66sQNKOOs;//OO) /rI   c                    V ^8  d   QhRRRR/# r@  rD   )rE   s   "rF   rG   rH     s     0 00 
0rI   c                    V P                   '       d   \        R4      hV P                  '       d   \        R4      hV P                  e   \	        R4      hV P                  V4      # )z3Execute all operations, returning no results (w=0).z3Collation is unsupported for unacknowledged writes.z6arrayFilters is unsupported for unacknowledged writes.zGCannot set bypass_document_validation with unacknowledged write concern)rQ   r   rR   rK   r    rD  )rX   r   s   &&rF   execute_no_results_ClientBulk.execute_no_results  sc    
 $%Z[["""$%]^^*"Y  ))$//rI   c               $    V ^8  d   QhRRRRRR/# )r7   r   r   r'  rb   rB   r   rD   )rE   s   "rF   rG   rH     s(     
 
(
 
 
	
rI   c                T   V P                   '       g   \        R4      hV P                  '       d   \        R4      hRV n        \        WP                  4      pV P                  P
                  '       gi   V P                  P                  W4      ;_uu_ 4       pVP                  ^8  d   \        R4      hV P                  V4       \        RRR4      uuRRR4       # V P                  W4      p\        VV P                  P
                  V P                  4      #   + '       g   i     LL; i)zExecute operations.zNo operations to executez*Bulk operations can only be executed once.Tr6  NF)rL   r   rP   r   r:   r   r8   _conn_for_writesr7  rH  r-   r=  rA   )rX   r   r'  
connectionr   s   &&&  rF   execute_ClientBulk.execute  s     xxx"#=>>==="#OPP1';M;MN!!...--gAAZ..3*V  ''
3,T5%@ BA %%g9$++  
 	
 BAs   :DD'	)rK   r8   r?   rP   rN   rU   r@   rM   rL   r;   rV   rW   rO   rR   rQ   rA   r:   )TNNNF)NNNNN)NNNN)NNr]   )__name__
__module____qualname____firstlineno____doc__rY   propertyr^   rk   r}   r   r   r   r   r   r   r   r   r$  r=  rD  rH  rN  __static_attributes__rD   rI   rF   r5   r5   W   s    >-> ' '	%N>, Y YvWr
'
/2FhIV3j(0T0"
 
rI   r5   )PrT  
__future__r   r  r   r   collections.abcr   	itertoolsr   typingr   r   r   r   r	   r
   bson.objectidr   bson.raw_bsonr   pymongor   r   "pymongo.synchronous.client_sessionr   r   pymongo.synchronous.collectionr   "pymongo.synchronous.command_cursorr   pymongo.synchronous.databaser   pymongo.synchronous.helpersr    pymongo.synchronous.mongo_clientr   pymongo.synchronous.poolr   pymongo._client_bulk_sharedr   r   pymongo.commonr   r   r   pymongo.errorsr   r   r   r   r    r!   r"   pymongo.helpers_sharedr#   pymongo.loggerr$   r%   r&   pymongo.messager'   r(   r)   r*   r+   pymongo.read_preferencesr,   pymongo.resultsr-   r.   r/   r0   pymongo.typingsr1   r2   pymongo.write_concernr3   _IS_SYNCr5   rD   rI   rF   <module>rp     s    #    *   # ) ! ] 5 < 1 6<3 
   : M M  4  4 .d

 d

rI   