+
    8iy                       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)AsyncClientSession_validate_session_write_concern)AsyncCollection)AsyncCommandCursor)AsyncDatabase)_handle_reauth)AsyncMongoClient)AsyncConnection)_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)WriteConcernFc                     ] 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# ))_AsyncClientBulkz4The 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AsyncMongoClient[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/asynchronous/client_bulk.py__annotate___AsyncClientBulk.__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 _AsyncClientBulk 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___AsyncClientBulk.__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_AsyncClientBulk.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_AsyncClientBulk.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_AsyncClientBulk.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_AsyncClientBulk.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_AsyncClientBulk.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      G Rj  xL
 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      G Rj  xL
  V#  EL~ L	  \:         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      '       d@   T P4                  P7                  T
PB                  TP8                  4      G Rj  xL 
   Rp
?
T# T P4                  P7                  / TP8                  4      G Rj  xL 
   Rp
?
T# Rp
?
ii ; i5i)zHA proxy for AsyncConnection.write_command that handles event publishing.rL   nsInfomessageclientIdcommandcommandNamedatabaseName	requestIdoperationIddriverConnectionIdserverConnectionId
serverHost
serverPort	serviceIdN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error)%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   _AsyncClientBulk.write_command   sp     E
H''66-5522?? cO [[$&#&88;;#&88#@#@88++A.88++A.((-- ;;;JJs99	E((00#))LLE((,,.?H++GMM::#1;;#66CC' $T#Y!$( *'*xx{{'*xx'D'D"xx//2"xx//2!hh11  {{{Z9++//{{CCCF s M, D !	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kk33CKKMMM  kk33BDDDE!	Es   DTT&)K KAK -CK :K KK TK K S>BS9+C-S9AS98R;9S9>T)S9-S0.S93T9S>>T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                N	  "   \         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      G Rj  xL
 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
#  ELp  \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5i)zFA proxy for AsyncConnection.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   _AsyncClientBulk.unack_write@  s6     ''66-5522?? cO [[$&#&88;;#&88#@#@88++A.88++A.((-- ;;;**Sg?C9	#88//5F5FGGF((,,.?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@ s H4  	#((,,.?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?	#sd   DR%R%(J9 J6A;J9 CJ9 "J9 4R%6J9 9R"B=RC-R1&R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           	        "   VP                  W#V4      w  rVrxV P                  WWVWxV P                  4      G Rj  xL
  Wx3#  L5i)z6Executes a batch of bulkWrite server commands (unack).N)batch_commandr   r8   )	rX   r   rj   rL   rM   r   r   to_send_ops
to_send_nss	   &&&&&    rF   _execute_batch_unack%_AsyncClientBulk._execute_batch_unack  sN      473D3DSz3Z0
s+SWS^S^___&& 	`s   7AAA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           	        "   VP                  W#V4      w  rVrxV P                  WWVWxV P                  4      G Rj  xL
 p	WV3#  L5i)z4Executes a batch of bulkWrite server commands (ack).N)r   r   r8   )
rX   r   rj   rL   rM   r   r   r   r   r   s
   &&&&&     rF   _execute_batch_AsyncClientBulk._execute_batch  sR      473D3DSz3Z0
))j{
 
 J..
s   7AA	Ac          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r7   full_resultr   r   r   r   r   Optional[AsyncClientSession]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dq   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      G Rj  xL
   V  Rj  xL
  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#  EL LDR#   \"         dE   pTP$                  '       d   TP'                  4       G Rj  xL 
  \)        T4      TR&    Rp?R# Rp?ii ; i5i)z?Internal helper for processing the server reply command cursor.cursorTadminz$cmd.bulkWrite)databaser   )r   r?   Nidxr   writeErrorsrf   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(_AsyncClientBulk._process_results_cursor  s     ::h'+$"&t{{G<%D ,x J 224888F!+ O O#%(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HK   9O(  F###$**,,,"@"Ew	Fs    G'A'G'
FG'F FFFA)F F G'F F ,AF G'FF G'G$ %GGGG'G$$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           	       "   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dA   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      G Rj  xL
 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      G Rj  xL
  \U        V P2                  V P
                  VV4       RV n.        RV n        MV P_                  WW4      G Rj  xL
 w  ppV ;P
                  \Y        V4      ,          un        VR
,          '       g(   V P                  '       g   EKH  VR,          '       g   EKZ  R# R#  EL6 L Lh5i)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!_AsyncClientBulk._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 )))373F3FsQT3a-a*
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 22;VVV txx+vN !&/4, (,'@'@3'[![QOOs;//O 7##]9S9SY /H .bn W "\s   B2W	52W	(W	W	
AW	 W	0W	W	W	!C+W	W!W	/W	!W	-:W	(2W	W	5W	=W	W	CW	0W	BW	WA
W	WAW	,W	>W	W	W	c               $    V ^8  d   QhRRRRRR/# )r7   r   r   	operationrb   rB   r   rD   )rE   s   "rF   rG   rH   r  s(     3 3-3 3 
"	3rI   c                b  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      G Rj  xL
  SR,          '       g   SR,          '       g   SR,          '       d   \	        SS P
                  4       S#  LI5i)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   6_AsyncClientBulk.execute_command.<locals>.__annotate__  s0     	 	1	!	 	 		rI   c                   <"   VP                   ^8  d   \        R4      hSP                  SP                  V VSVS4      G Rj  xL
  R#  L5i)   <MongoClient.bulk_write requires MongoDB server version 8.0+.N)max_wire_versionr   r$  r:   )r   r   r   r   r   rX   s   &&&rF   retryable_bulk8_AsyncClientBulk.execute_command.<locals>.retryable_bulk  sX     
 $$r)&R  ''""  s   A AA
A)bulkoperation_id)r+   r8   _retryable_writerU   r   rA   )rX   r   r'  r8  r   r   s   f&& @@rF   execute_command _AsyncClientBulk.execute_commandr  s      UT2 "RRR1
 
	 	$ kk** + 
 	
 	
 w;}#=#=MaAbAb.{D<P<PQ	
s$   AB/#B-$B/7B/B/B/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      G Rj  xL
 w  rV ;P
                  \        V
4      ,          un        EK$  R#  L-5i)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&_AsyncClientBulk.execute_command_unack  sO    
 KK00	
!!KK%%
 oo."C $C"C	N"".262E2E./#&(C|||!%Ixxx!XXE
$4??D9C$GJ $(#<#<Ss#WWNKOOs;//OO) /$ Xs   B/E:2 E:A7E:
E8.E:c                    V ^8  d   QhRRRR/# r@  rD   )rE   s   "rF   rG   rH     s     6 66 
6rI   c                   "   V P                   '       d   \        R4      hV P                  '       d   \        R4      hV P                  e   \	        R4      hV P                  V4      G Rj  xL
 #  L5i)z3Execute all operations, returning no results (w=0).z3Collation is unsupported for unacknowledged writes.z6arrayFilters is unsupported for unacknowledged writes.NzGCannot set bypass_document_validation with unacknowledged write concern)rQ   r   rR   rK   r    rD  )rX   r   s   &&rF   execute_no_results#_AsyncClientBulk.execute_no_results  sl     
 $%Z[["""$%]^^*"Y  //5555s   /A18A1*A/+A1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                  "   V P                   '       g   \        R4      hV P                  '       d   \        R4      hRV n        \        WP                  4      pV P                  P
                  '       g   V P                  P                  W4      G Rj  xL
 ;_uu_4       GRj  xL
 pVP                  ^8  d   \        R4      hV P                  V4      G Rj  xL
  \        RRR4      uuRRR4      GRj  xL
  # V P                  W4      G Rj  xL
 p\        VV P                  P
                  V P                  4      #  L L Lk LO  + GRj  xL 
 '       g   i     Le; i LS5i)zExecute operations.zNo operations to executez*Bulk operations can only be executed once.TNr6  F)rL   r   rP   r   r:   r   r8   _conn_for_writesr7  rH  r-   r=  rA   )rX   r   r'  
connectionr   s   &&&  rF   execute_AsyncClientBulk.execute  s%     xxx"#=>>==="#OPP1';M;MN!!...![[99'MMMMMQ[..3*V  --j999,T5%@ NMM ++G??$++  
 	
 N
 : NMMM @s   /E'A!E'EE'$E%E'(1E	EE	*E'7E8E'E%0E'E'E	E'	E"	E
E"	E"		E')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6"
 
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.asynchronous.client_sessionr   r   pymongo.asynchronous.collectionr   #pymongo.asynchronous.command_cursorr   pymongo.asynchronous.databaser   pymongo.asynchronous.helpersr   !pymongo.asynchronous.mongo_clientr   pymongo.asynchronous.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    #    *   # ) ! c ; B 7 7B9 
   : M M  4  4 .f

 f

rI   