
    ~ZiC                       S SK Jr  S SKJrJrJrJr  S SKJrJ	r	  \
r\
r\\   r\\\4   r\
r\S\\
\\4   r\\S   \S   \S   4   r " S S	\	\S
9r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r\\\\\4   r  " S S\	5      r! " S S\	5      r" " S S \	5      r# " S! S"\	5      r$ " S# S$\	5      r%\\!\"\#\$\%4   r&\\\\\\ \&4   r'\\\\!\\#\%\ \4   r(\\\4   r) " S% S&\	5      r* " S' S(\	5      r+\\*\+4   r, " S) S*\	5      r- " S+ S,\	5      r. " S- S.\	5      r/ " S/ S0\	\S
9r0 " S1 S2\	5      r1\\-\.\/\14   r2 " S3 S4\	5      r3 " S5 S6\	5      r4 " S7 S8\	5      r5 " S9 S:\	5      r6\\4\5\64   r7 " S; S<\	5      r8 " S= S>\	5      r9 " S? S@\	5      r:\\9\:4   r; " SA SB\	5      r< " SC SD\	5      r= " SE SF\	5      r>\\<\=\>4   r? " SG SH\	5      r@ " SI SJ\@\45      rA " SK SL\@\55      rB " SM SN\@\65      rC " SO SP\@\95      rD " SQ SR\@\:5      rE " SS ST\@\<5      rF " SU SV\@\=5      rG " SW SX\@\>5      rH " SY SZ\	5      rI " S[ S\\	5      rJ " S] S^\	5      rK " S_ S`\	5      rL " Sa Sb\	5      rM " Sc Sd\	5      rN " Se Sf\	5      rO " Sg Sh\	5      rP " Si Sj\	5      rQ " Sk Sl\	5      rR " Sm Sn\	5      rS\\K\L\M\N\O\P\Q\R\S4	   rT " So Sp\	5      rU " Sq Sr\U\K5      rV " Ss St\U\L5      rW " Su Sv\U\M5      rX " Sw Sx\U\N5      rY " Sy Sz\U\O5      rZ " S{ S|\U\P5      r[ " S} S~\U\Q5      r\ " S S\U\R5      r] " S S\U\S5      r^\\V\W\X\Y\Z\[\\\]\^4	   r_\\I\J\_4   r` " S S\	5      ra " S S\	5      rb " S S\	5      rc " S S\	5      rd " S S\	5      re " S S\	5      rf " S S\	5      rg " S S\	5      rh\\S   \S   \S   \S   \S   \S   \S   \S   \S   \S   4
   ri " S S\	5      rj\3rk " S S\@\k5      rl " S S\	5      rm\\S   \S   \S   \S   \S   \S   \S   \S   \S   \\S4   4
   rn " S S\	5      ro " S S\	5      rp " S S\	5      rq " S S\	5      rr " S S\	5      rs\\b\c\d4   rt\8ru\\k\7\u\;\?4   rv " S S\@\u5      rw\\l\A\B\C\w\D\E\F\G\H4
   rx " S S\	5      ry " S S\	5      rz\\S   \S   \S   \S   \S   4   r{ " S S\	5      r| " S S\	5      r} " S S\	5      r~\\|\}\~4   r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r\\\\\\\4   r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r\\\\\4   r " S S\	5      r " S S\	5      r " S S\	5      r\dr " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r " S S\	5      r\\f\g\h\d4   r\\a\t\e\\\d4   r " S S\	5      r\\S   \S   \S   \S   4   r " S S\	5      r " S S\	5      rg)    )annotations)	AnnotatedAnyLiteralUnion)NotRequired	TypedDictNaihumansystemc                  \    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S\S'   S\S	'   S
rg)MessageMetadata   NotRequired[str]providermodel
model_typerun_id	thread_idsystem_fingerprintservice_tier N__name__
__module____qualname____firstlineno____annotations____static_attributes__r       u/var/www/eduai.edurigo.com/question_generate/ques_gen_env/lib/python3.13/site-packages/langchain_protocol/protocol.pyr   r      s,      ((""r    r   )extra_itemsc                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)TextContentBlock   zLiteral['text']typestrtextr   idNotRequired[BlockIndex]indexzNotRequired[list[Annotation]]r   r   Nr   r   r    r!   r$   r$      s    

I""..r    r$   c                  R    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S	\S
'   Srg)InvalidToolCall&   zLiteral['invalid_tool_call']r&   Union[str, None]r)   nameargserrorr*   r+   r   Nr   r   r    r!   r-   r-   &   s&    
&&

""r    r-   c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	rg
)ReasoningContentBlock.   zLiteral['reasoning']r&   r   	reasoningr)   r*   r+   r   Nr   r   r    r!   r4   r4   .   s    
""r    r4   c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
rg)NonStandardContentBlock4   zLiteral['non_standard']r&   dict[str, Any]valuer   r)   r*   r+   r   Nr   r   r    r!   r8   r8   4   s    
!!""r    r8   c                  \    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)ImageContentBlock:   zLiteral['image']r&   r   r)   file_idurlbase64	mime_typer*   r+   r   Nr   r   r    r!   r=   r=   :   ,    
	""r    r=   c                  \    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)VideoContentBlockC   zLiteral['video']r&   r   r)   r?   r@   rA   rB   r*   r+   r   Nr   r   r    r!   rE   rE   C   rC   r    rE   c                  \    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)AudioContentBlockL   zLiteral['audio']r&   r   r)   r?   r@   rA   rB   r*   r+   r   Nr   r   r    r!   rH   rH   L   rC   r    rH   c                  \    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)FileContentBlockU   zLiteral['file']r&   r   r)   r?   r@   rA   rB   r*   r+   r   Nr   r   r    r!   rK   rK   U   s,    
	""r    rK   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)ToolCall`   zLiteral['tool_call']r&   r/   r)   r'   r0   r:   r1   r*   r+   r   Nr   r   r    r!   rN   rN   `   s    

I
""r    rN   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S	'   S
rg)ToolCallChunkg   zLiteral['tool_call_chunk']r&   r/   r)   r0   r1   r*   r+   r   Nr   r   r    r!   rQ   rQ   g   s     
$$

""r    rQ   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	\S
'   Srg)ServerToolCalln   zLiteral['server_tool_call']r&   r'   r)   r0   r:   r1   r*   r+   r   Nr   r   r    r!   rT   rT   n   s    
%%G
I
""r    rT   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S	'   S
rg)ServerToolCallChunku   z!Literal['server_tool_call_chunk']r&   r   r)   r0   r1   r*   r+   r   Nr   r   r    r!   rW   rW   u   s     
++

""r    rW   c                  R    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
\S'   S\S'   Srg)ServerToolResult|   zLiteral['server_tool_result']r&   r'   tool_call_idz+Union[Literal['success'], Literal['error']]statusr   r)   NotRequired[Any]outputr*   r+   r   Nr   r   r    r!   rZ   rZ   |   s&    
''77""r    rZ   c                  \    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S\S	'   S\S
'   S\S'   Srg)Citation   zLiteral['citation']r&   r   r)   r@   titleNotRequired[int]start_index	end_index
cited_textr   Nr   r   r    r!   ra   ra      s,    
	!!  r    ra   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
NonStandardAnnotation   z"Literal['non_standard_annotation']r&   r   r)   r:   r;   r   Nr   r   r    r!   ri   ri      s    
,,r    ri   c                  *    \ rS rSr% S\S'   S\S'   Srg)	TextDelta   zLiteral['text-delta']r&   r'   r(   r   Nr   r   r    r!   rl   rl      s    

Ir    rl   c                  *    \ rS rSr% S\S'   S\S'   Srg)ReasoningDelta   zLiteral['reasoning-delta']r&   r'   r6   r   Nr   r   r    r!   ro   ro      s    
$$Nr    ro   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
	DataDelta   zLiteral['data-delta']r&   r'   datazNotRequired[Literal['base64']]encodingr   Nr   r   r    r!   rr   rr      s    

I,,r    rr   c                       \ rS rSr% S\S'   Srg)BlockDeltaFields   r'   r&   r   Nr   r   r    r!   rw   rw      s    
Ir    rw   c                  *    \ rS rSr% S\S'   S\S'   Srg)
BlockDelta   zLiteral['block-delta']r&   rw   fieldsr   Nr   r   r    r!   rz   rz      s    
  r    rz   c                  *    \ rS rSr% S\S'   S\S'   Srg)RunInput   zLiteral['run.input']methodRunInputParamsparamsr   Nr   r   r    r!   r~   r~            r    r~   c                  *    \ rS rSr% S\S'   S\S'   Srg)SubscriptionSubscribe   z!Literal['subscription.subscribe']r   SubscribeParamsr   r   Nr   r   r    r!   r   r          --r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)SubscriptionUnsubscribe   z#Literal['subscription.unsubscribe']r   UnsubscribeParamsr   r   Nr   r   r    r!   r   r      s    //r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)SubscriptionReconnect   z!Literal['subscription.reconnect']r   ReconnectParamsr   r   Nr   r   r    r!   r   r      r   r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)AgentGetTree   zLiteral['agent.getTree']r   AgentGetTreeParamsr   r   Nr   r   r    r!   r   r          $$r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)InputRespond   zLiteral['input.respond']r   InputRespondParamsr   r   Nr   r   r    r!   r   r      r   r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)InputInject   zLiteral['input.inject']r   InputInjectParamsr   r   Nr   r   r    r!   r   r      s    ##r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)StateGet   zLiteral['state.get']r   StateGetParamsr   r   Nr   r   r    r!   r   r      r   r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)StateListCheckpoints   z Literal['state.listCheckpoints']r   ListCheckpointsParamsr   r   Nr   r   r    r!   r   r      s    ,,!!r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)	StateFork   zLiteral['state.fork']r   StateForkParamsr   r   Nr   r   r    r!   r   r      s    !!r    r   c                       \ rS rSr% S\S'   Srg)_CommandFields   JsUintr)   r   Nr   r   r    r!   r   r      s    Jr    r   c                      \ rS rSrSrg)_CommandVariant1   r   Nr   r   r   r   r   r   r    r!   r   r          r    r   c                      \ rS rSrSrg)_CommandVariant2   r   Nr   r   r    r!   r   r      r   r    r   c                      \ rS rSrSrg)_CommandVariant3   r   Nr   r   r    r!   r   r      r   r    r   c                      \ rS rSrSrg)_CommandVariant5   r   Nr   r   r    r!   r   r      r   r    r   c                      \ rS rSrSrg)_CommandVariant6   r   Nr   r   r    r!   r   r      r   r    r   c                      \ rS rSrSrg)_CommandVariant7   r   Nr   r   r    r!   r   r      r   r    r   c                      \ rS rSrSrg)_CommandVariant8   r   Nr   r   r    r!   r   r      r   r    r   c                      \ rS rSrSrg)_CommandVariant9   r   Nr   r   r    r!   r   r      r   r    r   c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
rg)CommandResponse   zLiteral['success']r&   r   r)   
ResultDataresultNotRequired[ResponseMeta]metar   Nr   r   r    r!   r   r      s    
J
##r    r   c                  R    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
\S'   S\S'   Srg)ErrorResponsei  Literal['error']r&   zUnion[JsUint, None]r)   	ErrorCoder2   r'   messager   
stacktracer   r   r   Nr   r   r    r!   r   r     s%    
L  
##r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)LifecycleEventi	  zLiteral['lifecycle']r   r:   r   r   Nr   r   r    r!   r   r   	  r   r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)MessagesEventi  zLiteral['messages']r   r:   r   r   Nr   r   r    r!   r   r     s    r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)
ToolsEventi  zLiteral['tools']r   r:   r   r   Nr   r   r    r!   r   r         r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)
InputEventi  zLiteral['input.requested']r   r:   r   r   Nr   r   r    r!   r   r     s    &&r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)ValuesEventi  zLiteral['values']r   r:   r   r   Nr   r   r    r!   r   r         r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)UpdatesEventi  zLiteral['updates']r   r:   r   r   Nr   r   r    r!   r   r     s    r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)CheckpointsEventi!  zLiteral['checkpoints']r   r:   r   r   Nr   r   r    r!   r   r   !  s    ""r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)CustomEventi%  zLiteral['custom']r   r:   r   r   Nr   r   r    r!   r   r   %  r   r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)
TasksEventi)  zLiteral['tasks']r   r:   r   r   Nr   r   r    r!   r   r   )  r   r    r   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
_EventFieldsi/  zLiteral['event']r&   r   event_idNotRequired[JsUint]seqr   Nr   r   r    r!   r   r   /  s    
	r    r   c                      \ rS rSrSrg)_EventVariant0i4  r   Nr   r   r    r!   r   r   4  r   r    r   c                      \ rS rSrSrg)_EventVariant1i7  r   Nr   r   r    r!   r   r   7  r   r    r   c                      \ rS rSrSrg)_EventVariant2i:  r   Nr   r   r    r!   r   r   :  r   r    r   c                      \ rS rSrSrg)_EventVariant3i=  r   Nr   r   r    r!   r   r   =  r   r    r   c                      \ rS rSrSrg)_EventVariant4i@  r   Nr   r   r    r!   r   r   @  r   r    r   c                      \ rS rSrSrg)_EventVariant5iC  r   Nr   r   r    r!   r   r   C  r   r    r   c                      \ rS rSrSrg)_EventVariant6iF  r   Nr   r   r    r!   r   r   F  r   r    r   c                      \ rS rSrSrg)_EventVariant7iI  r   Nr   r   r    r!   r   r   I  r   r    r   c                      \ rS rSrSrg)_EventVariant8iL  r   Nr   r   r    r!   r   r   L  r   r    r   c                       \ rS rSr% S\S'   Srg)	RunResultiS  r   r   r   Nr   r   r    r!   r  r  S      r    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)SubscribeResultiV  r'   subscription_idrd   replayed_eventsr   Nr   r   r    r!   r  r  V  s    %%r    r  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
ReconnectResultiZ  boolrestoredrd   missed_eventsz#NotRequired[list[AgentStatusEntry]]current_namespacesr   Nr   r   r    r!   r  r  Z  s    N##;;r    r  c                      \ rS rSrSrg)EmptyResulti_  r   Nr   r   r    r!   r  r  _  r   r    r  c                       \ rS rSr% S\S'   Srg)AgentResultib  AgentTreeNodetreer   Nr   r   r    r!   r  r  b  s    
r    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)StateGetResultie  r:   valuesNotRequired[CheckpointRef]
checkpointr   Nr   r   r    r!   r  r  e  s    **r    r  c                       \ rS rSr% S\S'   Srg)ListCheckpointsResultii  zlist[CheckpointSummary]checkpointsr   Nr   r   r    r!   r  r  i  s    ((r    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)StateForkResultil  r'   r   r   r   Nr   r   r    r!   r  r  l  s    KNr    r  invalid_argumentunknown_commandunknown_errorno_such_runno_such_subscriptionno_such_namespaceno_such_interruptno_such_checkpointpermission_deniednot_supportedc                       \ rS rSr% S\S'   Srg)ResponseMetair  r   applied_through_seqr   Nr   r   r    r!   r(  r(  r  s    ,,r    r(  c                      \ rS rSrSrg)_CommandVariant0iw  r   Nr   r   r    r!   r+  r+  w  r   r    r+  c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	rg
)r   iz  r'   assistant_idr   inputNotRequired[dict[str, Any]]configmetadatar   Nr   r   r    r!   r   r   z  s    J''))r    r   r  updatesmessagestools	lifecycler.  r  taskscustomz	custom:.+c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
rg)EventStreamRequesti  list[Channel]channelsNotRequired[list[Namespace]]
namespacesrd   depthr   sincer   Nr   r   r    r!   r9  r9    s    ,,r    r9  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
r   i  r:  r;  r<  r=  rd   r>  r   Nr   r   r    r!   r   r     s    ,,r    r   c                       \ rS rSr% S\S'   Srg)r   i  r'   r  r   Nr   r   r    r!   r   r     s    r    r   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
r   i  r'   r   r   last_event_idNotRequired[list[str]]subscriptionsr   Nr   r   r    r!   r   r     s    K##))r    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)AgentStatusEntryi  	Namespace	namespaceAgentStatusr]   r   Nr   r   r    r!   rG  rG    s    r    rG  c                      \ rS rSrSrg)_CommandVariant4i  r   Nr   r   r    r!   rL  rL    r   r    rL  c                       \ rS rSr% S\S'   Srg)r   i  r   r   r   Nr   r   r    r!   r   r     r  r    r   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
\S'   Srg)r  i  rH  rI  rJ  r]   r'   
graph_namez NotRequired[list[AgentTreeNode]]childrenr/  r1  r   Nr   r   r    r!   r  r    s    O..))r    r  startedrunning	completedfailedinterruptedc                  *    \ rS rSr% S\S'   S\S'   Srg)LifecycleCauseToolCalli  zLiteral['toolCall']r&   r'   r\   r   Nr   r   r    r!   rW  rW    s    
r    rW  c                  *    \ rS rSr% S\S'   S\S'   Srg)LifecycleCauseSendi  zLiteral['send']r&   r'   	from_noder   Nr   r   r    r!   rY  rY        
Nr    rY  c                  *    \ rS rSr% S\S'   S\S'   Srg)LifecycleCauseEdgei  zLiteral['edge']r&   r'   rZ  r   Nr   r   r    r!   r]  r]    r[  r    r]  c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	\S
'   Srg)LifecycleDatai  rJ  eventr   rO  zNotRequired[LifecycleCause]causer2   r  r  r   Nr   r   r    r!   r_  r_    s       &&**r    r_  c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
rg)MessageStartDatai  zLiteral['message-start']r`  MessageRoleroler'   r)   zNotRequired[MessageMetadata]r1  r   Nr   r   r    r!   rc  rc    s    ##
G**r    rc  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
ContentBlockStartDatai  zLiteral['content-block-start']r`  intr+   ContentBlockcontentr   Nr   r   r    r!   rg  rg    s    ))Jr    rg  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
ContentBlockDeltaDatai  zLiteral['content-block-delta']r`  rh  r+   ContentBlockDeltadeltar   Nr   r   r    r!   rl  rl    s    ))Jr    rl  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
ContentBlockFinishDatai  zLiteral['content-block-finish']r`  rh  r+   FinalizedContentBlockrj  r   Nr   r   r    r!   rp  rp    s    **J""r    rp  c                  *    \ rS rSr% S\S'   S\S'   Srg)MessageFinishDatai  zLiteral['message-finish']r`  zNotRequired[UsageInfo]usager   Nr   r   r    r!   rs  rs    s    $$!!r    rs  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
MessageErrorDatai  r   r`  r'   r   r   coder   Nr   r   r    r!   rv  rv    s    L
r    rv  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg)	UsageInfoi  rd   input_tokensoutput_tokenstotal_tokensr   Nr   r   r    r!   ry  ry    s    ""##""r    ry  c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	rg
)ToolStartedDatai  zLiteral['tool-started']r`  r'   r\   	tool_namer^   r.  r   Nr   r   r    r!   r~  r~    s    ""Nr    r~  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg)	ToolOutputDeltaDatai  zLiteral['tool-output-delta']r`  r'   r\   rn  r   Nr   r   r    r!   r  r    s    ''Jr    r  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
ToolFinishedDatai  zLiteral['tool-finished']r`  r'   r\   r   r_   r   Nr   r   r    r!   r  r    s    ##Kr    r  c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	rg
)ToolErrorDatai  zLiteral['tool-error']r`  r'   r\   r   r   rw  r   Nr   r   r    r!   r  r    s      L
r    r  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
r   i  rH  rI  r'   interrupt_idr   responser   Nr   r   r    r!   r   r     s    Mr    r   c                  *    \ rS rSr% S\S'   S\S'   Srg)r   i  rH  rI  InputMessager   r   Nr   r   r    r!   r   r     s    r    r   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
r  i  z)Union[Literal['user'], Literal['system']]re  r'   rj  r   r0   r   Nr   r   r    r!   r  r    s    
33L
r    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)InputRequestedDatai  r'   r  r   payloadr   Nr   r   r    r!   r  r    s    Lr    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)r   i  rH  rI  rD  keysr   Nr   r   r    r!   r   r     s    
  r    r   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
r   i  zNotRequired[Namespace]rI  rd   limitr   beforer   Nr   r   r    r!   r   r     s    %%r    r   c                  H    \ rS rSr% S\S'   S\S'   S\S'   S\S'   S	\S
'   Srg)CheckpointSummaryi  r'   r)   	timestamprh  stepr   	node_namer/  r1  r   Nr   r   r    r!   r  r    s    GN
I))r    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)CheckpointRefi&  r'   r)   r   nsr   Nr   r   r    r!   r  r  &  s    Gr    r  c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg	)
r   i*  r'   checkpoint_idr^   r.  r/  r0  r   Nr   r   r    r!   r   r   *  s    ''r    r   c                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S	'   S
rg)
Checkpointi3  r'   r)   r   	parent_idrh  r  CheckpointSourcesourcer   Nr   r   r    r!   r  r  3  s    G
Ir    r  loopupdateforkc                  *    \ rS rSr% S\S'   S\S'   Srg)UpdatesDatai;  r   noder:   r  r   Nr   r   r    r!   r  r  ;  s    
r    r  c                  *    \ rS rSr% S\S'   S\S'   Srg)
CustomDatai?  r   r0   r   r  r   Nr   r   r    r!   r  r  ?  s    
Lr    r  )
__future__r   typingr   r   r   r   typing_extensionsr   r	   rh  JsIntr   listr'   rH  dict
Extensible	Timestampr	  floatMetadataScalarrd  r   r$   r-   r4   r8   r=   rE   rH   rK   DataContentBlockrN   rQ   rT   rW   rZ   ToolContentBlockri  rq  
BlockIndexra   ri   
Annotationrl   ro   rr   rw   rz   rm  r~   r   r   r   SubscriptionCommandr   r   r   InputCommandr   r   r   StateCommandr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   	EventDatar   r   r   r   r   r   r   r   r   r   EventMessager  r  r  r  r  r  r  r  r   r(  
RunCommandr+  r   Channelr9  r   r   r   rG  SubscriptionResultAgentCommandCommandDatarL  Commandr   r  rJ  rW  rY  r]  LifecycleCauser_  rc  rg  rl  rp  rs  rv  MessagesDatary  r~  r  r  r  	ToolsDatar   r   r  InputResultr  r   r   r  r  r   StateResultr   r  r  r  r  r   r    r!   <module>r     s	   # 1 1 4	I	#s(^
	tT3s23GDM77#3WX5FFG#i^ #/y /#i ##I ##i ##	 ##	 ##	 ##y # *,=?PRbbc #y ##I ##Y ##) ##y # =.BUWggh %8MOfhx  {K  K  L.0ExQ`bp  sC  EU  Wn  n  o 5#:
!y !I 
 8223
	 Y -	 -
yc   )^Y
JK y I i I  13JLaab 9 9 )  \;./y "9 "	  X3Y>?Y 	~'< 		~'> 		~'< 		~| 		~{ 		~x 		~'; 		~y 	$i $$I $Y I   ) 9 y )   .-ZVbdt  wB  DN  N  O	9 
	\> 		\= 		\: 		\: 		\; 		\< 		\#3 		\; 		\: 	 	nnnnn^ln|  M  O]  ]  	^
5
6	 &i &<i <
	) 	) +Y +)I )i  ',-w7H/I7SbKcelmze{  ~E  F\  ~]  _f  gz  _{  }D  EX  }Y  [b  cw  [x  zA  BU  zV  X_  `o  Xp  p  q	-9 - 
	~z 	*Y * !79#5wz7JGT[L\^efq^rt{  }D  uE  GN  O\  G]  _f  gn  _o  qx  yA  qB  DM  NQ  S^  N^  D_  _  ` i 
	 *i *
y  ?O[HI J 3\<Q]]^	~| 	  "24DFVXhjz  }M  O_  aq  sC  C  D *I * GI&	(:GK<PRYZbRcelmze{{|Y    -/ACUUV+I ++y +I 
I 
#Y #
"	 "y 
 %'<>SUkm~  AQ  Q  R#	 #
i ) 
y 
I  /#68H-WX	 
	 9 
  !Y !I 
*	 *I (i (
 N$9?KWX90+{KYdde
  )76?GH<MwW]^_ )  r    