+
    lHàjJ  ã                   óZ   € R t ^ RIt^ RIHt ^ RIHt ^ RIHt ^ RIH	t	H
t
Ht RR ltR tR# )	zBRoute connector calls through the normal dispatch policy pipeline.N)Úasdict)Ú
tool_error)ÚMAX_CALLS_PER_DISPATCH)Úassemble_resultsÚfill_remote_failureÚpartition_callsc           	      óP  € ^ RI Hp ^ RIHp \	        RV RV/.4      pV! VP
                  VRRVVR7      pV^ ,          p	T! V	P                  R4      ;'       g    R
4       \        P                  ! V	P                  4        U
Uu/ uF  w  r«V
R9   g   K  W«bK  	  upp
RR	7      # u upp
i )é    )Úrecord_data_use)Ú
run_remoteÚnameÚ	argumentsN)ÚavailabilityÚclient_factoryÚturn_idÚtask_idÚdata_useF©Úensure_ascii© >   ÚerrorÚaccountÚresponse)
Útools.connectors.data_user
   Útools.connectors.gateway.bridger   r   ÚremoteÚgetÚjsonÚdumpsÚitems)r   r   Útool_call_idr   r   r
   r   Ú	partitionÚentriesÚentryÚkeyÚvalues   &&&&&       Ú>/home/ubuntu/.hermes/hermes-agent/tools/connectors/dispatch.pyÚdispatch_connector_callr'      s›   € Ý9Ý:ä &¨$°¸YÐ!GÐ HÓI€IÙ˜×)Ñ)¨<ÀdÐ[_ÐipØ!(ô*€Gà�A�J€EÙ�E—I‘I˜jÓ)×/Ð/¨RÔ0Ü�:Š:°E·K±K´MÔm±M¡j cÀSÐLlÑEl”z�s’z±MÒmØ#(ô*ð *ùÓms   ÂB"
ÂB"
c                óÀ  € ^ RI Hp ^ RIHpHp	 ^ RIHp
 \        V 4      \        8”  d    \        R\        V 4       R\         R24      # \        V 4      pVP                  '       d   ^ RIHp \        V! V 4      4      # \        VP                  4      p\!        VP"                  4       EFâ  w  rïV
! 4       '       d.   VP%                  \'        VP"                  VR R	R
R7      4        EM§VP(                  '       d#   V! WP(                   RVP*                   2R7      MTpV	! R4      ;_uu_ 4        V! VP,                  VP.                  3/ \1        V4      BRVRVR\        V4      RRRRRRRVRV/B pRRR4        \3        X\4        4      '       d   \6        P8                  ! V4      MTpRVP*                  RVP,                  /p\3        V\<        4      '       d<   RV9   d5   VR,          p\3        V\<        4      '       d   TMRRR\5        V4      /VR&   M-\3        V\<        4      '       d   VP?                  RV4      MTVR&   \3        V\<        4      '       d$   VP?                  R4      '       d   VR,          VR&   VPA                  V4       EKå  	  \6        PB                  ! \E        \        V 4      V4      RR7      #   + '       g   i     ELR; i  \:         d    Xp EL6i ; i) r	   )Úreplace)Úhandle_function_callÚsuppress_post_tool_call_hook)Úis_interruptedztoo many calls: z > max z#. Retry with fewer calls per batch.)Úlocal_batch_errorNz.Stopped by the user before this call was made.ÚINTERRUPTED)ÚcodeÚ#)r    FÚ	user_taskÚenabled_toolsÚtool_request_middleware_traceÚskip_pre_tool_call_hookÚskip_tool_request_middlewareÚskip_tool_execution_middlewareÚenabled_toolsetsÚdisabled_toolsetsÚindexr   r   r/   Ú
TOOL_ERRORÚmessager   r   r   )#Údataclassesr)   Úmodel_toolsr*   r+   Útools.interruptr,   Úlenr   r   r   ÚlocalÚtools.tool_search_validationr-   ÚlistÚerrorsÚ	enumerater   Úextendr   r    Úpositionr   r   r   Ú
isinstanceÚstrr   ÚloadsÚ
ValueErrorÚdictr   Úappendr   r   )ÚcallsÚidsr1   r2   Úmiddleware_tracer7   r8   r)   r*   r+   r,   r!   r-   r"   ÚoffsetÚplanÚ	entry_idsÚpayloadr%   r#   r   s   &&$$$$$              r&   Údispatch_connector_batchrT      sœ  € å#çNÝ.ä
ˆ5ƒzÔ*Ô*ÜÐ,¬S°«Z¨L¸Ô@VÐ?Wð X>ð >ó ?ð 	?ä Ó&€IØ‡‡€ÝBÜÑ+¨EÓ2Ó3Ð3Ü�9×#Ñ#Ó$€GÜ! )×"2Ñ"2×3‰ˆÙ×Òà�N‰NÔ.Ø× Ñ   Ð)Ð+[Ø"ô$ô %ò ð Y\×Xh×XhÐXh‘G˜C×1AÑ1AÐ0BÀ!ÀDÇMÁMÀ?Ð.SÕTÐnqˆ	Ù)¨%×0Õ0Ù*Ø—	‘	˜4Ÿ>™>ñÜ-3°IÓ->ñØJSðà+ðäKOÐP`ÓKaðð ).ðð MRðð 05ð	ð
 "2ðð
 FWòˆG÷ 1ð	Ü+5°g¼s×+CÒ+C”D—J’J˜wÔ'ÈˆEð ˜$Ÿ-™-¨°·±Ð;ˆÜ�eœT×"Ò" w°%Ô'7Ø˜'•NˆEÜ&0°¼×&=Ò&=™UÀFÈLÐZcÔehÐinÓeoÐCpˆE�'ŠNä@JÈ5ÔRV×@WÒ@W §	¡	¨*°eÔ <Ð]bˆE�*ÑÜ�eœT×"Ò" u§y¡y°×';Ò';Ø$ YÕ/ˆE�)ÑØ�‰�u×ñ= 4ô> �:Š:Ô&¤s¨5£z°7Ó;È%ÔPÐP÷+ 1×0Ð0ûô ô 	Ø‹Eð	ús   Ä,AJ8Å8.KÊ8K	ËKËK)NN)Ú__doc__r   r<   r   Útools.registryr   Útools.connectors.gateway.configr   Útools.connectors.gateway.merger   r   r   r'   rT   r   ó    r&   Ú<module>rZ      s%   ðÙ Hã Ý å %Ý Bß aÑ aô
*ô.QrY   