
    <i>                       % S r SSKJr  SSKJrJr  SSKJr  SSKJrJ	r	J
r
JrJrJr  SSKJr  \\\\4      r \	S   r \	S   r \	S	   r \	S
   r \	S   r \	S   r \	S   r \	S   r \	S   r \	S   r \	S   r \	S   r \	S   r \	S   r  \	S   r! \	S   r" \\\4   r#S\$S'    " S S\SS9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/ " S/ S0\5      r0 " S1 S2\5      r1 " S3 S4\5      r2\	S5   r3\	S6   r4\	S7   r5\	S8   r6\\\\7\8\94      r:\\\\\:\\:   4   4   \;\<\\:4      \<\<\\:4   S94   \\=4   r> " S: S;\5      r? " S< S=\5      r@ " S> S?\5      rA " S@ SA\@SS9rB " SB SC\5      rC " SD SE\
5      rD " SF SG\5      rE " SH SI\SS9rF " SJ SK\5      rGgL)Mz3Data models for interacting with the LangGraph API.    )annotations)MappingSequence)datetime)AnyLiteral
NamedTupleOptional	TypedDictUnion)	TypeAlias)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exit*)creater#   )r$   r%   )assistant_idgraph_idname
created_at
updated_at)	thread_idstatusr3   r4   )cron_idr0   r5   r3   r4   next_run_date)ascdescr   Contextc                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)Config   z!Configuration options for a call.	list[str]tagsintrecursion_limitdict[str, Any]configurable N__name__
__module____qualname____firstlineno____doc____annotations____static_attributes__rE       d/home/dmtnaga/Documents/work/airagagent/rag_env/lib/python3.13/site-packages/langgraph_sdk/schema.pyr=   r=      s)    +
O
  ! rN   r=   F)totalc                  H    \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'   S
rg)
Checkpoint   z1Represents a checkpoint in the execution process.strr5   checkpoint_ns
str | Nonecheckpoint_iddict[str, Any] | Nonecheckpoint_maprE   NrF   rE   rN   rO   rR   rR      s(    ;NKQ?))BrN   rR   c                  `    \ rS rSr% SrS\S'    S\S'    S\S'    S\S'    S\S	'    S\S
'   Srg)GraphSchema   z0Defines the structure and properties of a graph.rT   r1   dict | Noneinput_schemaoutput_schemastate_schemaconfig_schemacontext_schemarE   NrF   rE   rN   rO   r[   r[      sD    :M=====rN   r[   c                      \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S
\S'    S\S'    S\S'    S\S'    S\S'   Srg)AssistantBase   zBase model for an assistant.rT   r0   r1   r=   configr;   contextr   r3   JsonmetadatarA   versionr2   rV   descriptionrE   NrF   rE   rN   rO   rd   rd      sQ    &"MN.-N!L&
I#*rN   rd   c                      \ rS rSrSrSrg)AssistantVersion   z.Represents a specific version of an assistant.rE   N)rG   rH   rI   rJ   rK   rM   rE   rN   rO   rm   rm      s    8rN   rm   c                  $    \ rS rSr% SrS\S'   Srg)	Assistant   z3Represents an assistant with additional properties.r   r4   rE   NrF   rE   rN   rO   rp   rp      s    =2rN   rp   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)		Interrupt   z1Represents an interruption in the execution flow.r   valuerT   idrE   NrF   rE   rN   rO   rs   rs      s    ;J2GGrN   rs   c                  l    \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S
\S'    S\S'    S\S'   Srg)Threadi  z!Represents a conversation thread.rT   r5   r   r3   r4   rh   ri   ThreadStatusr6   r   zdict[str, list[Interrupt]]
interruptsrE   NrF   rE   rN   rO   rx   rx     sA    +N*/NIL***JrN   rx   c                  `    \ rS rSr% SrS\S'   S\S'   S\S'   S\S	'   S
\S'   S\S'   S\S'   Srg)
ThreadTaski  z"Represents a task within a thread.rT   rv   r2   rV   r   list[Interrupt]rz   Checkpoint | None
checkpointzThreadState | NonestaterX   resultrE   NrF   rE   rN   rO   r|   r|     s-    ,G
I!!!!rN   r|   c                  x    \ rS rSr% SrS\S'    S\S'    S\S'    S	\S
'    S\S'    S\S'    S\S'    S\S'   Srg)ThreadStatei!  z!Represents the state of a thread.zlist[dict] | dict[str, Any]r   zSequence[str]nextrR   r   rh   ri   rV   r3   r~   parent_checkpointzSequence[ThreadTask]r   r}   rz   rE   NrF   rE   rN   rO   r   r   !  sN    +''
#N!%((ST6rN   r   c                  $    \ rS rSr% SrS\S'   Srg)ThreadUpdateStateResponsei7  z7Represents the response from updating a thread's state.rR   r   rE   NrF   rE   rN   rO   r   r   7  s    A)rN   r   c                  x    \ rS rSr% SrS\S'    S\S'    S\S'    S\S'    S\S	'    S
\S'    S\S'    S\S'   Srg)Runi>  z"Represents a single execution run.rT   run_idr5   r0   r   r3   r4   	RunStatusr6   rh   ri   MultitaskStrategymultitask_strategyrE   NrF   rE   rN   rO   r   r   >  sJ    ,KN3',kN))@rN   r   c                      \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S\S
'    S\S'    S\S'    S\S'    S\S'    S\S'    S\S'   Srg)CroniS  zRepresents a scheduled task.rT   r7   r0   rV   r5   zdatetime | Noneend_timescheduler   r3   r4   dictpayloaduser_idr8   ri   rE   NrF   rE   rN   rO   r   r   S  sd    &L"0M+(-M6"""(N#rN   r   )
r0   r1   r2   rk   rf   rg   r3   r4   ri   rj   )	r5   r3   r4   ri   rf   rg   r6   r   rz   )	r   r5   r0   r3   r4   r6   ri   kwargsr   )r7   r0   r5   r   r   r3   r4   r   r   r8   ri   now.c                      \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S
\S'    S\S'    S\S'    S\S'    S\S'    S\S'    S\S'   Srg)	RunCreatei  z7Defines the parameters for initiating a background run.rV   r5   rT   r0   r]   inputri   zConfig | Nonerf   zContext | Nonerg   rW   zlist[str] | Noneinterrupt_beforeinterrupt_afterwebhookzMultitaskStrategy | Noner   rE   NrF   rE   rN   rO   r   r     sh    AU>)8,(8&&;%%:E00CrN   r   c                  T    \ rS rSr% SrS\S'    S\S'    S\S'    S	\S
'    S	\S'   Srg)Itemi  zqRepresents a single document or data entry in the graph's Store.

Items are used to store cross-thread memories.
r?   	namespacerT   keyrC   ru   r   r3   r4   rE   NrF   rE   rN   rO   r   r     s9    
 X	H D27rN   r   c                  $    \ rS rSr% SrS\S'   Srg)ListNamespaceResponsei  z*Response structure for listing namespaces.zlist[list[str]]
namespacesrE   NrF   rE   rN   rO   r   r     s    4JrN   r   c                  $    \ rS rSr% SrS\S'   Srg)
SearchItemi  zItem 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scorerE   NrF   rE   rN   rO   r   r     s     rN   r   c                  $    \ rS rSr% SrS\S'   Srg)SearchItemsResponsei  z'Response structure for searching items.zlist[SearchItem]itemsrE   NrF   rE   rN   rO   r   r     s    17rN   r   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	
StreamParti  z'Represents a part of a stream response.rT   eventr   datarE   NrF   rE   rN   rO   r   r     s    1J1
J5rN   r   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	Sendi  zRepresents 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.
rT   noderX   r   rE   NrF   rE   rN   rO   r   r     s     I=  7rN   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)Commandi  a  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   resumerE   NrF   rE   rN   rO   r   r     s-     ,+ 76
 KrN   r   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	RunCreateMetadatai,  z$Metadata for a run creation request.rT   r   rV   r5   rE   NrF   rE   rN   rO   r   r   ,  s    .KrN   r   N)HrK   
__future__r   collections.abcr   r   r   typingr   r   r	   r
   r   r   typing_extensionsr   r   rT   rh   r   ry   ThreadStreamMode
StreamModeDisconnectModer   OnConflictBehaviorOnCompletionBehavior
DurabilityAllIfNotExistsCancelActionAssistantSortByThreadSortBy
CronSortBy	SortOrderr;   rL   r=   rR   r[   	Subgraphsrd   rm   rp   rs   rx   r|   r   r   r   r   AssistantSelectFieldThreadSelectFieldRunSelectFieldCronSelectFieldrA   floatboolPrimitiveDatalisttuplebytesQueryParamTypesr   r   r   r   r   r   r   r   r   rE   rN   rO   <module>r      sR   9 " -   (S#X jVW	 => CD  


 -. HI  23  /0  ,-
@
 cl .() ./ B HI W
 M"	 #s(^ #Ye .
C 
C=) =, k!"	+I +.	} 	3 3H	 HKY K&	" 	"7) 7,*	 *A) A*$9 $< 	  
  
  sC456C}h}&==>>?sM!	"#	%]"
#S
()		D	 D689 8*KI KU 8) 86 679 7iu 6 	  rN   