§
    ™ŠtjÇp  ã                  ó	  — U d Z ddlmZ ddlmZmZ ddlmZ ddlmZ ddl	m
Z
mZmZmZmZmZmZ ddlmZmZ eee
f         dz  Z	 ed	         Z	 ed
         Z	 ed         Z	 ed         Z	 ed         Z	 ed         Z	 ed         Z	 ed         Z	 ed         Z	  G d„ ded¬¦  «        Z ed         Z!	 ed         Z"	 ed         Z#	 ed         Z$	 ed         Z%	 ed         Z&	 ed         Z'	 ed         Z(	 ed         Z)	  G d„ d ed¬¦  «        Z* G d!„ d"e¦  «        Z+ G d#„ d$e¦  «        Z,eee,f         Z- G d%„ d&e¦  «        Z. G d'„ d(e.¦  «        Z/ G d)„ d*e.¦  «        Z0 G d+„ d,e¦  «        Z1 G d-„ d.e¦  «        Z2 G d/„ d0e¦  «        Z3 G d1„ d2e¦  «        Z4 G d3„ d4e¦  «        Z5 G d5„ d6e¦  «        Z6 G d7„ d8e¦  «        Z7 G d9„ d:e¦  «        Z8 G d;„ d<ed¬¦  «        Z9ed=         Z:ed>         Z;ed?         Z<ed@         Z=ee>z  e?z  e@z  dz  ZAeeeAeeA         z  f         eBeCeeAf                  z  eCeCeeAf         dAf         z  ez  eDz  ZE G dB„ dCe¦  «        ZF G dD„ dEe¦  «        ZG G dF„ dGe¦  «        ZH G dH„ dIeGd¬¦  «        ZI G dJ„ dKe¦  «        ZJ G dL„ dMe¦  «        ZKedN         ZL	  G dO„ dPe¦  «        ZM G dQ„ dRe¦  «        ZN G dS„ dTe¦  «        ZO G dU„ dVe¦  «        ZP G dW„ dXe¦  «        ZQ G dY„ dZe¦  «        ZR G d[„ d\e¦  «        ZSeQeRz  eSz  ZT	  G d]„ d^e¦  «        ZU G d_„ d`e¦  «        ZV G da„ dbe¦  «        ZW G dc„ dde¦  «        ZX G de„ dfe¦  «        ZY G dg„ dhe¦  «        ZZ G di„ dje¦  «        Z[ G dk„ dle¦  «        Z\ G dm„ dne¦  «        Z] G do„ dpe¦  «        Z^ G dq„ dre¦  «        Z_ G ds„ dte¦  «        Z`eVeWz  eXz  eYz  eZz  e[z  e\z  e]z  e^z  e_z  e`z  Za	  G du„ dve¦  «        Zb G dw„ dxed¬¦  «        Zc G dy„ dze¦  «        Zd G d{„ d|e¦  «        Ze G d}„ d~e¦  «        Zf G d„ d€e¦  «        Zg G d�„ d‚e¦  «        Zhdez  e>z  e?z  e@z  Zidƒejd„<   eeeeieBei         d…eBd…         f         f         Zkdƒejd…<   eeefz  egz  ehz  ekz  Zldƒejd†<   elZmdƒejd‡<   dS )ˆz3Data models for interacting with the LangGraph API.é    )Úannotations)ÚMappingÚSequence)ÚField)Údatetime)ÚAnyÚClassVarÚLiteralÚ
NamedTupleÚProtocolÚ	TypeAliasÚUnion)ÚNotRequiredÚ	TypedDictN)ÚpendingÚrunningÚerrorÚsuccessÚtimeoutÚinterrupted)ÚidleÚbusyr   r   )Ú	run_modesÚ	lifecycleÚstate_update)	ÚvaluesÚmessagesÚupdatesÚeventsÚtasksÚcheckpointsÚdebugÚcustomzmessages-tuple)ÚcancelÚcontinue)ÚrejectÚ	interruptÚrollbackÚenqueue)ÚraiseÚ
do_nothing)ÚdeleteÚkeep)ÚsyncÚasyncÚexitc                  ó*   — e Zd ZU dZded<   	 ded<   dS )ÚLangSmithTracingz$Configuration for LangSmith tracing.ÚstrÚproject_nameÚ
example_idN©Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__© ó    úR/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph_sdk/schema.pyr2   r2   o   s0   € € € € € € Ø.Ð.àÐÐÑØ1Ø€O€O�OØGÐGr=   r2   F)ÚtotalÚ*)Úcreater&   )r,   Úkeep_latest)r'   r(   )r   r   Úall)Úassistant_idÚgraph_idÚnameÚ
created_atÚ
updated_at)Ú	thread_idÚstatusrG   rH   Ústate_updated_at)Úcron_idrD   rI   rG   rH   Únext_run_dateÚend_time)ÚascÚdescc                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚConfigz!Configuration options for a call.ú	list[str]ÚtagsÚintÚrecursion_limitúdict[str, Any]ÚconfigurableNr6   r<   r=   r>   rR   rR   ¹   sK   € € € € € € Ø+Ð+à€O€O�Oðð
 ÐÐÑðð !Ð Ð Ñ ðð r=   rR   c                  óB   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   d	S )
Ú
Checkpointz1Represents a checkpoint in the execution process.r3   rI   Úcheckpoint_nsú
str | NoneÚcheckpoint_idúdict[str, Any] | NoneÚcheckpoint_mapNr6   r<   r=   r>   rZ   rZ   Ð   sN   € € € € € € Ø;Ð;à€N€N�NØKØÐÐÑØQØÐÐÑØ?Ø)Ð)Ð)Ñ)ØBÐBr=   rZ   c                  óZ   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded	<   d
S )ÚGraphSchemaz0Defines the structure and properties of a graph.r3   rE   údict | NoneÚinput_schemaÚoutput_schemaÚstate_schemaÚconfig_schemaÚcontext_schemaNr6   r<   r=   r>   ra   ra   Ý   sx   € € € € € € Ø:Ð:à€M€M�MØØÐÐÑð=àÐÐÑð=àÐÐÑð=àÐÐÑð=àÐÐÑð=ð =r=   ra   c                  ó~   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   	 ded<   	 ded<   	 ded<   dS )ÚAssistantBasezBase model for an assistant.r3   rD   rE   rR   ÚconfigÚContextÚcontextr   rG   ÚJsonÚmetadatarU   ÚversionrF   r\   ÚdescriptionNr6   r<   r=   r>   ri   ri   ö   s�   € € € € € € Ø&Ð&àÐÐÑØ"Ø€M€M�MØØ€N€N�NØØÐÐÑØ.ØÐÐÑØ-Ø€N€N�NØ!Ø€L€L�LØ&Ø€I€I�IØ#ØÐÐÑØ*Ð*r=   ri   c                  ó   — e Zd ZdZdS )ÚAssistantVersionz.Represents a specific version of an assistant.N)r7   r8   r9   r:   r<   r=   r>   rr   rr     s   € € € € € Ø8Ð8à€Dr=   rr   c                  ó   — e Zd ZU dZded<   dS )Ú	Assistantz3Represents an assistant with additional properties.r   rH   Nr6   r<   r=   r>   rt   rt     s$   € € € € € € Ø=Ð=àÐÐÑØ2Ð2r=   rt   c                  ó*   — e Zd ZU dZded<   	 ded<   dS )ÚAssistantsSearchResponsez0Paginated response for assistant search results.zlist[Assistant]Ú
assistantsr\   ÚnextNr6   r<   r=   r>   rv   rv     s3   € € € € € € Ø:Ð:àÐÐÑØ>ØÐÐÑØKÐKr=   rv   c                  ó*   — e Zd ZU dZded<   	 ded<   dS )Ú	Interruptz1Represents an interruption in the execution flow.r   Úvaluer3   ÚidNr6   r<   r=   r>   rz   rz   #  s-   € € € € € € Ø;Ð;à€J€J�JØ2Ø€G€G�GØGÐGr=   rz   c                  ór   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   	 ded<   	 ded<   dS )ÚThreadz!Represents a conversation thread.r3   rI   r   rG   rH   rm   rn   ÚThreadStatusrJ   r   zdict[str, list[Interrupt]]Ú
interruptszNotRequired[dict[str, Any]]Ú	extractedNr6   r<   r=   r>   r~   r~   ,  s„   € € € € € € Ø+Ð+à€N€N�NØØÐÐÑØ*ØÐÐÑØ/Ø€N€N�NØØÐÐÑØIØ€L€L�LØ*Ø*Ð*Ð*Ñ*ØJØ*Ð*Ð*Ñ*Ø[Ð[r=   r~   c                  óZ   — e Zd ZU dZded<   ded<   ded<   ded<   d	ed
<   ded<   ded<   dS )Ú
ThreadTaskz"Represents a task within a thread.r3   r|   rF   r\   r   úlist[Interrupt]r€   úCheckpoint | NoneÚ
checkpointzThreadState | NoneÚstater^   ÚresultNr6   r<   r=   r>   rƒ   rƒ   A  sf   € € € € € € Ø,Ð,à€G€G�GØ€I€I�IØÐÐÑØÐÐÑØ!Ð!Ð!Ñ!ØÐÐÑØ!Ð!Ð!Ñ!Ð!Ð!r=   rƒ   c                  ór   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded	<   	 d
ed<   	 ded<   	 ded<   	 ded<   dS )ÚThreadStatez!Represents the state of a thread.zlist[dict] | dict[str, Any]r   zSequence[str]rx   rZ   r†   rm   rn   r\   rG   r…   Úparent_checkpointzSequence[ThreadTask]r    r„   r€   Nr6   r<   r=   r>   rŠ   rŠ   M  sŒ   € € € € € € Ø+Ð+à'Ð'Ð'Ñ'ØØÐÐÑðàÐÐÑØ#Ø€N€N�NØ!ØÐÐÑØ%Ø(Ð(Ð(Ñ(ØSØÐÐÑØTØÐÐÑØ6Ð6r=   rŠ   c                  ó   — e Zd ZU dZded<   dS )ÚThreadUpdateStateResponsez7Represents the response from updating a thread's state.rZ   r†   Nr6   r<   r=   r>   r�   r�   c  s$   € € € € € € ØAÐAàÐÐÑØ)Ð)r=   r�   c                  ór   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   	 ded<   dS )ÚRunz"Represents a single execution run.r3   Úrun_idrI   rD   r   rG   rH   Ú	RunStatusrJ   rm   rn   ÚMultitaskStrategyÚmultitask_strategyNr6   r<   r=   r>   r�   r�   j  s„   € € € € € € Ø,Ð,à€K€K�KØØ€N€N�NØØÐÐÑØ3ØÐÐÑØ'ØÐÐÑØ,ØÐÐÑØkØ€N€N�NØØ)Ð)Ð)Ñ)Ø@Ð@r=   r�   c                  óº   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 d	ed<   	 ded<   	 ded<   dS )ÚCronzRepresents a scheduled task.r3   rL   rD   r\   rI   zOnCompletionBehavior | NoneÚon_run_completedzdatetime | NonerN   ÚscheduleÚtimezoner   rG   rH   ÚdictÚpayloadÚuser_idrM   rn   ÚboolÚenabledNr6   r<   r=   r>   r•   r•     sØ   € € € € € € Ø&Ð&à€L€L�LØØÐÐÑØ"ØÐÐÑØØ1Ð1Ð1Ñ1ØbØÐÐÑØ0Ø€M€M�MØ+ØÐÐÑØsØÐÐÑØ(ØÐÐÑØ-Ø€M€M�MØ6ØÐÐÑØ"Ø"Ð"Ð"Ñ"Ø(Ø€N€N�NØ#Ø€M€M�MØ&Ð&r=   r•   c                  óÒ   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   dS )Ú
CronUpdatez9Payload for updating a cron job. All fields are optional.r3   r—   r˜   r   rN   ÚInputÚinputrW   rn   rR   rj   rk   rl   ÚwebhookzAll | list[str]Úinterrupt_beforeÚinterrupt_afterÚOnCompletionBehaviorr–   rœ   r�   zStreamMode | list[StreamMode]Ústream_modeÚstream_subgraphsÚstream_resumableÚ
DurabilityÚ
durabilityNr6   r<   r=   r>   rŸ   rŸ      só   € € € € € € ØCÐCà€M€M�MØ3Ø€M€M�MØHØÐÐÑØ0Ø€L€L�LØ!ØÐÐÑØ2Ø€N€N�NØ.ØÐÐÑØ0Ø€L€L�LØ;Ø%Ð%Ð%Ñ%ØBØ$Ð$Ð$Ñ$ØAØ*Ð*Ð*Ñ*Ø=Ø€M€M�MØ)Ø.Ð.Ð.Ñ.Ø$ØÐÐÑØ2ØÐÐÑØSØÐÐÑØRÐRr=   rŸ   )
rD   rE   rF   rp   rj   rl   rG   rH   rn   ro   )	rI   rG   rH   rn   rj   rl   rJ   r   r€   )	r�   rI   rD   rG   rH   rJ   rn   Úkwargsr“   )rL   rD   rI   rN   r—   r˜   rG   rH   r›   rš   rM   rn   Únowr–   r�   .c                  ó–   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   	 ded<   dS )Ú	RunCreatez7Defines the parameters for initiating a background run.r\   rI   r3   rD   rb   r¡   rn   zConfig | Nonerj   zContext | Nonerl   r]   zlist[str] | Noner£   r¤   r¢   zMultitaskStrategy | Noner“   Nr6   r<   r=   r>   r®   r®   
  sº   € € € € € € ØAÐAàÐÐÑØUØÐÐÑØ>ØÐÐÑØ)ØÐÐÑØ8ØÐÐÑØ,ØÐÐÑØ(ØÐÐÑØ8Ø&Ð&Ð&Ñ&Ø;Ø%Ð%Ð%Ñ%Ø:ØÐÐÑØEØ0Ð0Ð0Ñ0ØCÐCr=   r®   c                  óN   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded	<   	 ded
<   dS )ÚItemzyRepresents a single document or data entry in the graph's Store.

    Items are used to store cross-thread memories.
    rS   Ú	namespacer3   ÚkeyrW   r{   r   rG   rH   Nr6   r<   r=   r>   r°   r°   %  sg   € € € € € € ðð ð
 ÐÐÑØXØ€H€H�Hðð ÐÐÑØDØÐÐÑØ2ØÐÐÑØ7Ð7r=   r°   c                  ó   — e Zd ZU dZded<   dS )ÚListNamespaceResponsez*Response structure for listing namespaces.zlist[list[str]]Ú
namespacesNr6   r<   r=   r>   r´   r´   :  s$   € € € € € € Ø4Ð4àÐÐÑØJÐJr=   r´   c                  ó   — e Zd ZU dZded<   dS )Ú
SearchItemzæItem with an optional relevance score from search operations.

    Attributes:
        score (Optional[float]): Relevance/similarity score. Included when
            searching a compatible store with a natural language query.
    zfloat | NoneÚscoreNr6   r<   r=   r>   r·   r·   A  s*   € € € € € € ðð ð ÐÐÑÐÐr=   r·   c                  ó   — e Zd ZU dZded<   dS )ÚSearchItemsResponsez'Response structure for searching items.zlist[SearchItem]ÚitemsNr6   r<   r=   r>   rº   rº   L  s$   € € € € € € Ø1Ð1àÐÐÑØ7Ð7r=   rº   c                  ó:   — e Zd ZU dZded<   	 ded<   	 dZded<   dS )	Ú
StreamPartz'Represents a part of a stream response.r3   Úeventr™   ÚdataNr\   r|   )r7   r8   r9   r:   r;   r|   r<   r=   r>   r½   r½   S  sA   € € € € € € Ø1Ð1à€J€J�JØ1Ø€J€J�JØ5Ø€BÐÐÐÑØÐr=   r½   )Úv1Úv2c                  óB   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   d	S )
ÚTaskPayloadzPayload for a task start event.r3   r|   rF   r   r¡   rS   ÚtriggersNr6   r<   r=   r>   rÃ   rÃ   i  sH   € € € € € € Ø)Ð)à€G€G�GØ*Ø€I€I�IØ*Ø€J€J�JØ(ØÐÐÑØVÐVr=   rÃ   c                  óN   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   dS )ÚTaskResultPayloadz Payload for a task result event.r3   r|   rF   r\   r   úlist[dict[str, Any]]r€   rW   rˆ   Nr6   r<   r=   r>   rÆ   rÆ   v  sZ   € € € € € € Ø*Ð*à€G€G�GØ*Ø€I€I�IØ-ØÐÐÑØ=Ø$Ð$Ð$Ñ$ØAØÐÐÑØFÐFr=   rÆ   c                  óZ   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 d	ed
<   	 ded<   dS )ÚCheckpointTaskPayloada  A task entry within a `CheckpointPayload`.

    The keys present depend on the task's state:

    - **Error:** `id`, `name`, `error`, `state`
    - **Has result:** `id`, `name`, `result`, `interrupts`, `state`
    - **Pending:** `id`, `name`, `interrupts`, `state`
    r3   r|   rF   zNotRequired[str]r   zNotRequired[Any]rˆ   z!NotRequired[list[dict[str, Any]]]r€   r^   r‡   Nr6   r<   r=   r>   rÉ   rÉ   …  so   € € € € € € ðð ð €G€G�GØ*Ø€I€I�IØ*ØÐÐÑØ9ØÐÐÑØNØ1Ð1Ð1Ñ1ØVØ Ð Ð Ñ ØCÐCr=   rÉ   c                  óZ   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded<   	 ded	<   	 d
ed<   dS )ÚCheckpointPayloadzPayload for a checkpoint event.r^   rj   rW   rn   r   rS   rx   Úparent_configzlist[CheckpointTaskPayload]r    Nr6   r<   r=   r>   rË   rË   �  sl   € € € € € € Ø)Ð)à!Ð!Ð!Ñ!Ø[ØÐÐÑØVØÐÐÑØ>Ø€O€O�OØ7Ø(Ð(Ð(Ñ(Ø\Ø&Ð&Ð&Ñ&Ø8Ð8r=   rË   c                  ó>   — e Zd ZU ded<   	 ded<   	 ded<   	 ded<   d	S )
Ú_DebugCheckpointPayloadrU   Ústepr3   Ú	timestampzLiteral['checkpoint']ÚtyperË   rš   N©r7   r8   r9   r;   r<   r=   r>   rÎ   rÎ   ®  sE   € € € € € € Ø€I€I�IØ1Ø€N€N�NØ9ØÐÐÑØ:ØÐÐÑØ!Ð!r=   rÎ   c                  ó>   — e Zd ZU ded<   	 ded<   	 ded<   	 ded<   d	S )
Ú_DebugTaskPayloadrU   rÏ   r3   rÐ   zLiteral['task']rÑ   rÃ   rš   NrÒ   r<   r=   r>   rÔ   rÔ   ¹  sE   € € € € € € Ø€I€I�IØ1Ø€N€N�NØ9ØÐÐÑØ4ØÐÐÑØ!Ð!r=   rÔ   c                  ó>   — e Zd ZU ded<   	 ded<   	 ded<   	 ded<   d	S )
Ú_DebugTaskResultPayloadrU   rÏ   r3   rÐ   zLiteral['task_result']rÑ   rÆ   rš   NrÒ   r<   r=   r>   rÖ   rÖ   Ä  sE   € € € € € € Ø€I€I�IØ1Ø€N€N�NØ9Ø Ð Ð Ñ Ø;ØÐÐÑØ"Ð"r=   rÖ   c                  ó   — e Zd ZU dZded<   dS )ÚRunMetadataPayloadz)Payload for the `metadata` control event.r3   r�   Nr6   r<   r=   r>   rØ   rØ   Ó  s!   € € € € € € Ø3Ð3à€K€K�KØ+Ð+r=   rØ   c                  óB   — e Zd ZU dZded<   	 ded<   	 ded<   	 ded	<   d
S )ÚValuesStreamPartz/Stream part emitted for `stream_mode="values"`.zLiteral['values']rÑ   rS   ÚnsrW   r¿   rÇ   r€   Nr6   r<   r=   r>   rÚ   rÚ   Ý  sN   € € € € € € Ø9Ð9àÐÐÑØ)Ø€M€M�MØEØÐÐÑØ+Ø$Ð$Ð$Ñ$Ø<Ð<r=   rÚ   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚUpdatesStreamPartz0Stream part emitted for `stream_mode="updates"`.zLiteral['updates']rÑ   rS   rÛ   rW   r¿   Nr6   r<   r=   r>   rÝ   rÝ   ê  s?   € € € € € € Ø:Ð:àÐÐÑØ)Ø€M€M�MØEØÐÐÑØ1Ð1r=   rÝ   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚMessagesPartialStreamPartzDStream part emitted for partial message chunks (`messages/partial`).zLiteral['messages/partial']rÑ   rS   rÛ   rÇ   r¿   Nr6   r<   r=   r>   rß   rß   õ  s?   € € € € € € ØNÐNà%Ð%Ð%Ñ%Ø)Ø€M€M�MØEØÐÐÑØ.Ð.r=   rß   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚMessagesCompleteStreamPartz@Stream part emitted for complete messages (`messages/complete`).zLiteral['messages/complete']rÑ   rS   rÛ   rÇ   r¿   Nr6   r<   r=   r>   rá   rá      s?   € € € € € € ØJÐJà&Ð&Ð&Ñ&Ø)Ø€M€M�MØEØÐÐÑØ)Ð)r=   rá   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚMessagesMetadataStreamPartz?Stream part emitted for message metadata (`messages/metadata`).zLiteral['messages/metadata']rÑ   rS   rÛ   rW   r¿   Nr6   r<   r=   r>   rã   rã     s?   € € € € € € ØIÐIà&Ð&Ð&Ñ&Ø)Ø€M€M�MØEØÐÐÑØRÐRr=   rã   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚMessagesTupleStreamPartzMStream part emitted for `stream_mode="messages"` (raw message+metadata pair).zLiteral['messages']rÑ   rS   rÛ   rÇ   r¿   Nr6   r<   r=   r>   rå   rå     s?   € € € € € € ØWÐWàÐÐÑØ)Ø€M€M�MØEØÐÐÑØ>Ð>r=   rå   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚCustomStreamPartz/Stream part emitted for `stream_mode="custom"`.zLiteral['custom']rÑ   rS   rÛ   r   r¿   Nr6   r<   r=   r>   rç   rç   !  s<   € € € € € € Ø9Ð9àÐÐÑØ)Ø€M€M�MØEØ€I€I�IØCÐCr=   rç   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚCheckpointsStreamPartz4Stream part emitted for `stream_mode="checkpoints"`.zLiteral['checkpoints']rÑ   rS   rÛ   rË   r¿   Nr6   r<   r=   r>   ré   ré   ,  s?   € € € € € € Ø>Ð>à Ð Ð Ñ Ø)Ø€M€M�MØEØÐÐÑØ!Ð!r=   ré   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚTasksStreamPartz.Stream part emitted for `stream_mode="tasks"`.zLiteral['tasks']rÑ   rS   rÛ   zTaskPayload | TaskResultPayloadr¿   Nr6   r<   r=   r>   rë   rë   7  s?   € € € € € € Ø8Ð8àÐÐÑØ)Ø€M€M�MØEØ)Ð)Ð)Ñ)Ø,Ð,r=   rë   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚDebugStreamPartz.Stream part emitted for `stream_mode="debug"`.zLiteral['debug']rÑ   rS   rÛ   ÚDebugPayloadr¿   Nr6   r<   r=   r>   rí   rí   B  s?   € € € € € € Ø8Ð8àÐÐÑØ)Ø€M€M�MØEØÐÐÑØ"Ð"r=   rí   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚMetadataStreamPartz3Control event with `run_id` and other run metadata.zLiteral['metadata']rÑ   rS   rÛ   rØ   r¿   Nr6   r<   r=   r>   rð   rð   M  s?   € € € € € € Ø=Ð=àÐÐÑØ)Ø€M€M�MØ0ØÐÐÑØ#Ð#r=   rð   c                  ó*   — e Zd ZU dZded<   	 ded<   dS )ÚSendzÚRepresents a message to be sent to a specific node in the graph.

    This type is used to explicitly send messages to nodes in the graph, typically
    used within Command objects to control graph execution flow.
    r3   Únoder^   r¡   Nr6   r<   r=   r>   rò   rò   k  s:   € € € € € € ðð ð €I€I�IØ=Ø Ð Ð Ñ ð7ð 7r=   rò   c                  ó6   — e Zd ZU dZded<   	 ded<   	 ded<   dS )	ÚCommanda  Represents one or more commands to control graph execution flow and state.

    This type defines the control commands that can be returned by nodes to influence
    graph execution. It lets you navigate to other nodes, update graph state,
    and resume from interruptions.
    z!Send | str | Sequence[Send | str]Úgotoz*dict[str, Any] | Sequence[tuple[str, Any]]Úupdater   ÚresumeNr6   r<   r=   r>   rõ   rõ   z  sQ   € € € € € € ðð ð ,Ð+Ð+Ñ+ðð 7Ð6Ð6Ñ6ðð
 €K€K�Kðð r=   rõ   c                  ó*   — e Zd ZU dZded<   	 ded<   dS )ÚRunCreateMetadataz$Metadata for a run creation request.r3   r�   r\   rI   Nr6   r<   r=   r>   rú   rú   •  s0   € € € € € € Ø.Ð.à€K€K�KØàÐÐÑØÐr=   rú   c                  ó(   — e Zd ZU dZded<   ded<   dS )Ú_TypedDictLikeV1zbProtocol to represent types that behave like TypedDicts

    Version 1: using `ClassVar` for keys.zClassVar[frozenset[str]]Ú__required_keys__Ú__optional_keys__Nr6   r<   r=   r>   rü   rü   Ÿ  s6   € € € € € € ð-ð -ð 0Ð/Ð/Ñ/Ø/Ð/Ð/Ñ/Ð/Ð/r=   rü   c                  ó(   — e Zd ZU dZded<   ded<   dS )Ú_TypedDictLikeV2zfProtocol to represent types that behave like TypedDicts

    Version 2: not using `ClassVar` for keys.zfrozenset[str]rý   rþ   Nr6   r<   r=   r>   r   r   ¨  s6   € € € € € € ð1ð 1ð &Ð%Ð%Ñ%Ø%Ð%Ð%Ñ%Ð%Ð%r=   r   c                  ó   — e Zd ZU dZded<   dS )Ú_DataclassLikez¡Protocol to represent types that behave like dataclasses.

    Inspired by the private _DataclassT from dataclasses that uses a similar protocol as a bound.
    zClassVar[dict[str, Field[Any]]]Ú__dataclass_fields__Nr6   r<   r=   r>   r  r  ±  s*   € € € € € € ðð ð
 :Ð9Ð9Ñ9Ð9Ð9r=   r  c                  ó0   — e Zd ZU dZded<   ded<   dd
„ZdS )Ú_BaseModelLikezBProtocol to represent types that behave like Pydantic `BaseModel`.zClassVar[dict[str, Any]]Úmodel_configzClassVar[Any]Ú__pydantic_core_schema__r«   r   ÚreturnrW   c                ó   — d S )Nr<   )Úselfr«   s     r>   Ú
model_dumpz_BaseModelLike.model_dumpÀ  s	   € ð ˜r=   N)r«   r   r  rW   )r7   r8   r9   r:   r;   r  r<   r=   r>   r  r  º  sH   € € € € € € ØLÐLà*Ð*Ð*Ñ*Ø+Ð+Ð+Ñ+ðð ð ð ð ð r=   r  r   Ú	_JSONLikeÚ_JSONMapr    rk   )nr:   Ú
__future__r   Úcollections.abcr   r   Údataclassesr   r   Útypingr   r	   r
   r   r   r   r   Útyping_extensionsr   r   r™   r3   rm   r‘   r   ÚThreadStreamModeÚ
StreamModeÚDisconnectModer’   ÚOnConflictBehaviorr¥   r©   r2   ÚAllÚIfNotExistsÚPruneStrategyÚCancelActionÚBulkCancelRunsStatusÚAssistantSortByÚThreadSortByÚ
CronSortByÚ	SortOrderrR   rZ   ra   Ú	Subgraphsri   rr   rt   rv   rz   r~   rƒ   rŠ   r�   r�   r•   rŸ   ÚAssistantSelectFieldÚThreadSelectFieldÚRunSelectFieldÚCronSelectFieldrU   Úfloatrœ   ÚPrimitiveDataÚlistÚtupleÚbytesÚQueryParamTypesr®   r°   r´   r·   rº   r½   ÚStreamVersionrÃ   rÆ   rÉ   rË   rÎ   rÔ   rÖ   rî   rØ   rÚ   rÝ   rß   rá   rã   rå   rç   ré   rë   rí   rð   ÚStreamPartV2rò   rõ   rú   rü   r   r  r  r  r;   r  r    rk   r<   r=   r>   ú<module>r-     sÄ  ðØ 9Ð 9Ð 9à "Ð "Ð "Ð "Ð "Ð "à -Ð -Ð -Ð -Ð -Ð -Ð -Ð -Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð 5Ð 4Ð 4Ð 4Ð 4Ð 4Ð 4Ð 4àˆC�ˆH„~˜Ñ€Ø jàÐVÔW€	ðð Ð=Ô>€ðð ÐCÔDÐ ðð ðô
€
ð
ð Ð-Ô.€ðð ÐHÔIÐ ðð Ð2Ô3Ð ðð Ð/Ô0Ð ðð Ð,Ô-€
ð@ðHð Hð Hð Hð H�y¨ð Hñ Hô Hð Hð ˆc„l€Ø .àÐ(Ô)€ðð Ð/Ô0€ðð Ð.Ô/€ðð Ð:Ô;Ð ðð ØBô€ðð ØIô€ðð ðô€
ðð �MÔ"€	ðð
ð ð ð ð ˆY˜eð ñ ô ð ð.
Cð 
Cð 
Cð 
Cð 
C�ñ 
Cô 
Cð 
Cð=ð =ð =ð =ð =�)ñ =ô =ð =ð, ��kÐ!Ô"€	ð+ð +ð +ð +ð +�Iñ +ô +ð +ð.	ð 	ð 	ð 	ð 	�}ñ 	ô 	ð 	ð3ð 3ð 3ð 3ð 3�ñ 3ô 3ð 3ðLð Lð Lð Lð L˜yñ Lô Lð LðHð Hð Hð Hð H�	ñ Hô Hð Hð\ð \ð \ð \ð \ˆYñ \ô \ð \ð*	"ð 	"ð 	"ð 	"ð 	"�ñ 	"ô 	"ð 	"ð7ð 7ð 7ð 7ð 7�)ñ 7ô 7ð 7ð,*ð *ð *ð *ð * 	ñ *ô *ð *ðAð Að Að Að Aˆ)ñ Aô Að Að*'ð 'ð 'ð 'ð 'ˆ9ñ 'ô 'ð 'ðB"Sð "Sð "Sð "Sð "S� %ð "Sñ "Sô "Sð "SðP ð	ôÐ ð ðô
Ð ð ðô
€ð ðô€ð$ �c‘	˜EÑ! DÑ(¨4Ñ/€ð ˆC� ¨-Ô!8Ñ8Ð8Ô9Ø
ˆ5��mÐ#Ô$Ô%ñ&àˆE�#�}Ð$Ô% sÐ*Ô+ñ,ð 
ñ
ð ñ	ð ðDð Dð Dð Dð D�	ñ Dô Dð Dð68ð 8ð 8ð 8ð 8ˆ9ñ 8ô 8ð 8ð*Kð Kð Kð Kð K˜Iñ Kô Kð Kðð ð ð ð �˜Uð ñ ô ð ð8ð 8ð 8ð 8ð 8˜)ñ 8ô 8ð 8ðð ð ð ð �ñ ô ð ð ˜
Ô#€ðð
Wð 
Wð 
Wð 
Wð 
W�)ñ 
Wô 
Wð 
WðGð Gð Gð Gð G˜	ñ Gô Gð GðDð Dð Dð Dð D˜Iñ Dô Dð Dð09ð 9ð 9ð 9ð 9˜	ñ 9ô 9ð 9ð""ð "ð "ð "ð "˜iñ "ô "ð "ð"ð "ð "ð "ð "˜	ñ "ô "ð "ð#ð #ð #ð #ð #˜iñ #ô #ð #ð 'Ð):Ñ:Ð=TÑT€Ø ?ð,ð ,ð ,ð ,ð ,˜ñ ,ô ,ð ,ð
=ð 
=ð 
=ð 
=ð 
=�yñ 
=ô 
=ð 
=ð2ð 2ð 2ð 2ð 2˜	ñ 2ô 2ð 2ð/ð /ð /ð /ð / 	ñ /ô /ð /ð*ð *ð *ð *ð * ñ *ô *ð *ðSð Sð Sð Sð S ñ Sô Sð Sð?ð ?ð ?ð ?ð ?˜iñ ?ô ?ð ?ðDð Dð Dð Dð D�yñ Dô Dð Dð"ð "ð "ð "ð "˜Iñ "ô "ð "ð-ð -ð -ð -ð -�iñ -ô -ð -ð#ð #ð #ð #ð #�iñ #ô #ð #ð$ð $ð $ð $ð $˜ñ $ô $ð $ð Øñàñ ð !ñ!ð !ñ	!ð
 ñð ñð ñð ñð ñ	ð ñ
ð ðð7ð 7ð 7ð 7ð 7ˆ9ñ 7ô 7ð 7ðð ð ð ð ˆi˜uð ñ ô ð ð6 ð  ð  ð  ð  ˜	ñ  ô  ð  ð0ð 0ð 0ð 0ð 0�xñ 0ô 0ð 0ð&ð &ð &ð &ð &�xñ &ô &ð &ð:ð :ð :ð :ð :�Xñ :ô :ð :ð	ð 	ð 	ð 	ð 	�Xñ 	ô 	ð 	ð ˜c‘z CÑ'¨%Ñ/°$Ñ6€	Ð 6Ð 6Ð 6Ñ 6ØØˆˆy˜$˜yœ/¨:°t¸JÔ7GÐGÔ	HÐHô€ð ð ð ñ ð
 Ð'Ñ'¨.Ñ8¸>ÑIÈHÑTð ð ð ð ñ ð €Ð Ð Ð Ñ Ð Ð r=   