
    =KiM                       % S r SSKJr  SSKJrJr  SSKJr  SSKJr  SSK	J
r
JrJrJrJrJrJr  SSKJr  \\\
4   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$ \S   r% \S   r& \S   r'  " 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      r0 " S- S.\5      r1 " S/ S0\5      r2 " S1 S2\5      r3 " S3 S4\5      r4 " S5 S6\5      r5 " S7 S8\5      r6 " S9 S:\SS9r7\S;   r8\S<   r9\S=   r:\S>   r;\\<-  \=-  \>-  S-  r?\\\?\\?   -  4   \@\A\\?4      -  \A\A\\?4   S?4   -  \-  \B-  rC " S@ SA\5      rD " SB SC\5      rE " SD SE\5      rF " SF SG\ESS9rG " SH SI\5      rH " SJ SK\5      rI " SL SM\5      rJ " SN SO\SS9rK " SP SQ\5      rL " SR SS\5      rM " ST SU\5      rN " SV SW\5      rO " SX SY\5      rPS\-  \<-  \=-  \>-  rQSZ\RS['   \\\\Q\@\Q   S\\@S\   4   4   rSSZ\RS\'   \M\N-  \O-  \P-  \S-  rTSZ\RS]'   \TrUSZ\RS^'   g)_z3Data models for interacting with the LangGraph API.    )annotations)MappingSequence)Field)datetime)AnyClassVarLiteral
NamedTupleProtocol	TypeAliasUnion)	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exit*)creater%   )r+   keep_latest)r&   r'   )r   r   all)assistant_idgraph_idname
created_at
updated_at)	thread_idstatusr7   r8   state_updated_at)cron_idr4   r9   r7   r8   next_run_dateend_time)ascdescc                  <    \ 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__rJ       V/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langgraph_sdk/schema.pyrB   rB      s)    +
O
  ! rS   rB   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.strr9   checkpoint_ns
str | Nonecheckpoint_iddict[str, Any] | Nonecheckpoint_maprJ   NrK   rJ   rS   rT   rW   rW      s(    ;NKQ?))BrS   rW   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.rY   r5   dict | Noneinput_schemaoutput_schemastate_schemaconfig_schemacontext_schemarJ   NrK   rJ   rS   rT   r`   r`      sD    :M=====rS   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.rY   r4   r5   rB   configContextcontextr   r7   JsonmetadatarF   versionr6   r[   descriptionrJ   NrK   rJ   rS   rT   ri   ri      sQ    &"MN.-N!L&
I#*rS   ri   c                      \ rS rSrSrSrg)AssistantVersioni  z.Represents a specific version of an assistant.rJ   N)rL   rM   rN   rO   rP   rR   rJ   rS   rT   rs   rs     s    8rS   rs   c                  $    \ rS rSr% SrS\S'   Srg)	Assistanti	  z3Represents an assistant with additional properties.r   r8   rJ   NrK   rJ   rS   rT   ru   ru   	  s    =2rS   ru   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	AssistantsSearchResponsei  z0Paginated response for assistant search results.zlist[Assistant]
assistantsr[   nextrJ   NrK   rJ   rS   rT   rw   rw     s    :>
KrS   rw   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)		Interrupti  z1Represents an interruption in the execution flow.r   valuerY   idrJ   NrK   rJ   rS   rT   r{   r{     s    ;J2GGrS   r{   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.rY   r9   r   r7   r8   rn   ro   ThreadStatusr:   r   zdict[str, list[Interrupt]]
interruptsrJ   NrK   rJ   rS   rT   r   r   "  sA    +N*/NIL***JrS   r   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)
ThreadTaski5  z"Represents a task within a thread.rY   r}   r6   r[   r   list[Interrupt]r   Checkpoint | None
checkpointzThreadState | Nonestater]   resultrJ   NrK   rJ   rS   rT   r   r   5  s-    ,G
I!!!!rS   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)ThreadStateiA  z!Represents the state of a thread.zlist[dict] | dict[str, Any]r   zSequence[str]ry   rW   r   rn   ro   r[   r7   r   parent_checkpointzSequence[ThreadTask]r   r   r   rJ   NrK   rJ   rS   rT   r   r   A  sN    +''
#N!%((ST6rS   r   c                  $    \ rS rSr% SrS\S'   Srg)ThreadUpdateStateResponseiW  z7Represents the response from updating a thread's state.rW   r   rJ   NrK   rJ   rS   rT   r   r   W  s    A)rS   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.rY   run_idr9   r4   r   r7   r8   	RunStatusr:   rn   ro   MultitaskStrategymultitask_strategyrJ   NrK   rJ   rS   rT   r   r   ^  sJ    ,KN3',kN))@rS   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\S'    S\S'   Srg)Cronis  zRepresents a scheduled task.rY   r<   r4   r[   r9   zOnCompletionBehavior | Noneon_run_completedzdatetime | Noner>   scheduler   r7   r8   dictpayloaduser_idr=   ro   boolenabledrJ   NrK   rJ   rS   rT   r   r   s  su    &L"11b0M+(-M6"""(N#M&rS   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\S'    S\S'    S\S'    S\S'   Srg)
CronUpdatei  z9Payload for updating a cron job. All fields are optional.rY   r   r   r>   InputinputrH   ro   rB   rk   rl   rm   webhookzAll | list[str]interrupt_beforeinterrupt_afterOnCompletionBehaviorr   r   r   zStreamMode | list[StreamMode]stream_modestream_subgraphsstream_resumable
Durability
durabilityrJ   NrK   rJ   rS   rT   r   r     s    CM30L!2N.0L;%%B$$A**=M)..$2SRrS   r   )
r4   r5   r6   rq   rk   rm   r7   r8   ro   rp   )	r9   r7   r8   ro   rk   rm   r:   r   r   )	r   r9   r4   r7   r8   r:   ro   kwargsr   )r<   r4   r9   r>   r   r7   r8   r   r   r=   ro   nowr   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)	RunCreatei  z7Defines the parameters for initiating a background run.r[   r9   rY   r4   rb   r   ro   zConfig | Nonerk   zContext | Nonerm   r\   zlist[str] | Noner   r   r   zMultitaskStrategy | Noner   rJ   NrK   rJ   rS   rT   r   r     sh    AU>)8,(8&&;%%:E00CrS   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.
rD   	namespacerY   keyrH   r|   r   r7   r8   rJ   NrK   rJ   rS   rT   r   r     s9    
 X	H D27rS   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]]
namespacesrJ   NrK   rJ   rS   rT   r   r   )  s    4JrS   r   c                  $    \ rS rSr% SrS\S'   Srg)
SearchItemi0  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scorerJ   NrK   rJ   rS   rT   r   r   0  s     rS   r   c                  $    \ rS rSr% SrS\S'   Srg)SearchItemsResponsei;  z'Response structure for searching items.zlist[SearchItem]itemsrJ   NrK   rJ   rS   rT   r   r   ;  s    17rS   r   c                  @    \ rS rSr% SrS\S'    S\S'    SrS\S	'   S
rg)
StreamPartiB  z'Represents a part of a stream response.rY   eventr   dataNr[   r}   rJ   )rL   rM   rN   rO   rP   rQ   r}   rR   rJ   rS   rT   r   r   B  s"    1J1
J5B
rS   r   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	SendiM  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.
rY   noder]   r   rJ   NrK   rJ   rS   rT   r   r   M  s     I=  7rS   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   resumerJ   NrK   rJ   rS   rT   r   r   \  s-     ,+ 76
 KrS   r   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	RunCreateMetadataiw  z$Metadata for a run creation request.rY   r   r[   r9   rJ   NrK   rJ   rS   rT   r   r   w  s    .KrS   r   c                  .    \ rS rSr% SrS\S'   S\S'   Srg)_TypedDictLikeV1i  z^Protocol to represent types that behave like TypedDicts

Version 1: using `ClassVar` for keys.zClassVar[frozenset[str]]__required_keys____optional_keys__rJ   NrK   rJ   rS   rT   r   r     s    - 0///rS   r   c                  .    \ rS rSr% SrS\S'   S\S'   Srg)_TypedDictLikeV2i  zbProtocol to represent types that behave like TypedDicts

Version 2: not using `ClassVar` for keys.zfrozenset[str]r   r   rJ   NrK   rJ   rS   rT   r   r     s    1 &%%%rS   r   c                  $    \ rS rSr% SrS\S'   Srg)_DataclassLikei  zProtocol 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__rJ   NrK   rJ   rS   rT   r   r     s    
 :9rS   r   c                  @    \ rS rSr% SrS\S'   S\S'       S
S jrSrg	)_BaseModelLikei  zBProtocol to represent types that behave like Pydantic `BaseModel`.zClassVar[dict[str, Any]]model_configzClassVar[Any]__pydantic_core_schema__c                    g )NrJ   )selfr   s     rT   
model_dump_BaseModelLike.model_dump  s     rS   rJ   N)r   r   returnrH   )rL   rM   rN   rO   rP   rQ   r   rR   rJ   rS   rT   r   r     s(    L**++ 
rS   r   r   	_JSONLike_JSONMapr   rl   )VrP   
__future__r   collections.abcr   r   dataclassesr   r   typingr   r	   r
   r   r   r   r   typing_extensionsr   r   rY   rn   r   r   ThreadStreamMode
StreamModeDisconnectModer   OnConflictBehaviorr   r   AllIfNotExistsPruneStrategyCancelActionBulkCancelRunsStatusAssistantSortByThreadSortBy
CronSortBy	SortOrderrB   rW   r`   	Subgraphsri   rs   ru   rw   r{   r   r   r   r   r   r   r   AssistantSelectFieldThreadSelectFieldRunSelectFieldCronSelectFieldrF   floatr   PrimitiveDatalisttuplebytesQueryParamTypesr   r   r   r   r   r   r   r   r   r   r   r   r   r   rQ   r   r   rl   rJ   rS   rT   <module>r      sJ   9 " -     (CH~ jVW	 => CD  


 -. HI  23  /0  ,-
@
 cl .() /0 ./ :;  B I 
 M"	
Ye .
C 
C=) =, k!"	+I +.	} 	3 3Ly LH	 HKY K&	" 	"7) 7,*	 *A) A*'9 '> S%  SL 	  
  
 " c	E!D(4/ C-!8889
5m#$%&E#}$%s*+, 

 	 D	 D689 8*KI KU 8) 8 79 7iu 6 	  0x 0&x &:X :	X 	 czC'%/$6	9 6y$y/:tJ7GG	HH) 
 ''.8>IHT y   rS   