+
    lHàj¾  ã                  óª   a € 0 t $ R t^ RIHt ^ RIt^ RIt^ RIHtHtH	t	 ]P                  ! RRR7      tR]R&   ]P                  R R	 l4       tR
 R ltR# )a  Data-use requirements of connector results, collected while one tool call dispatches.

The executor binds a sink around each dispatch and connector dispatch adds to it, so a batch's entries
union into the wrapper's sink and the requirement never rides the model-visible result string.
)ÚannotationsN)ÚIterableÚIteratorÚOptionalÚconnector_data_use)Údefaultz*contextvars.ContextVar[Optional[set[str]]]Ú_sinkc               ó   € V ^8„  d   QhRR/# )é   ÚreturnzIterator[set[str]]© )Úformats   "Ú>/home/ubuntu/.hermes/hermes-agent/tools/connectors/data_use.pyÚ__annotate__r      s   € ÷ ñ Ð,ñ ó    c               #  ó´   "  € \        4       p \        P                  V 4      p V x € \        P                  V4       R #   \        P                  T4       i ; i5i)N)Úsetr   Úreset)ÚsinkÚtokens     r   Úcollect_data_user      s;   é € ä“U€DÜ�I‰I�d‹O€EðØŠ
ä�‰�EÖøŒ�‰�EÕüs   ‚ A£> §A¾AÁAc               ó    € V ^8„  d   QhRRRR/# )r
   ÚrequireszIterable[str]r   ÚNoner   )r   s   "r   r   r      s   € ÷ ñ ˜mð °ñ r   c                ó\   € \         P                  4       pVe   VP                  V 4       R# R# )zYNo-op outside an agent dispatch (execute_code RPC, MCP serve): no message is built there.N)r   ÚgetÚupdate)r   r   s   & r   Úrecord_data_user      s$   € ä�9‰9‹;€DØÒØ�‰�HÖñ r   )Ú__conditional_annotations__Ú__doc__Ú
__future__r   Ú
contextlibÚcontextvarsÚtypingr   r   r   Ú
ContextVarr   Ú__annotations__Úcontextmanagerr   r   )r   s   @r   Ú<module>r'      sU   øðôõ #ã Û ß /Ñ /à4?×4JÒ4JÐK_ÐimÔ4n€Ð1Ó nð ×Ñôó ð÷r   