
    Zip                    
   % 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Jr  \\\
4   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   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      r0 " S+ S,\5      r1 " S- S.\5      r2 " S/ S0\5      r3 " S1 S2\5      r4 " S3 S4\5      r5 " S5 S6\5      r6 " S7 S8\5      r7 " S9 S:\5      r8 " S; S<\SS9r9\S=   r:\S>   r;\S?   r<\S@   r=\\>-  \?-  \@-  S-  rA\\\A\\A   -  4   \B\C\\A4      -  \C\C\\A4   SA4   -  \-  \D-  rE " SB SC\5      rF " SD SE\5      rG " SF SG\5      rH " SH SI\GSS9rI " SJ SK\5      rJ " SL SM\5      rK\SN   rL  " SO SP\5      rM " SQ SR\5      rN " SS ST\5      rO " SU SV\5      rP " SW SX\5      rQ " SY SZ\5      rR " S[ S\\5      rS\Q\R-  \S-  rT  " S] S^\5      rU " S_ S`\5      rV " Sa Sb\5      rW " Sc Sd\5      rX " Se Sf\5      rY " Sg Sh\5      rZ " Si Sj\5      r[ " Sk Sl\5      r\ " Sm Sn\5      r] " So Sp\5      r^ " Sq Sr\5      r_ " Ss St\5      r`\V\W-  \X-  \Y-  \Z-  \[-  \\-  \]-  \^-  \_-  \`-  ra  " Su Sv\5      rb " Sw Sx\SS9rc " Sy Sz\5      rd " S{ S|\5      re " S} S~\5      rf " S S\5      rg " S S\5      rhS\-  \>-  \?-  \@-  riS\jS'   \\\\i\B\i   S\BS   4   4   rkS\jS'   \e\f-  \g-  \h-  \k-  rlS\jS'   \lrmS\jS'   g)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                  0    \ rS rSr% SrS\S'    S\S'   Srg)LangSmithTracingo   z$Configuration for LangSmith tracing.strproject_name
example_id N__name__
__module____qualname____firstlineno____doc____annotations____static_attributes__r7       n/var/www/eduai.edurigo.com/question_generate/ques_gen_env/lib/python3.13/site-packages/langgraph_sdk/schema.pyr2   r2   o   s    .1OGr@   r2   F)total*)creater&   )r,   keep_latest)r'   r(   )r   r   all)assistant_idgraph_idname
created_at
updated_at)	thread_idstatusrJ   rK   state_updated_at)cron_idrG   rL   rJ   rK   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]configurabler7   Nr8   r7   r@   rA   rU   rU      s)    +
O
  ! r@   rU   c                  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.r4   rL   checkpoint_ns
str | Nonecheckpoint_iddict[str, Any] | Nonecheckpoint_mapr7   Nr8   r7   r@   rA   r^   r^      s(    ;NKQ?))Br@   r^   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.r4   rH   dict | Noneinput_schemaoutput_schemastate_schemaconfig_schemacontext_schemar7   Nr8   r7   r@   rA   rf   rf      sD    :M=====r@   rf   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.r4   rG   rH   rU   configContextcontextr   rJ   JsonmetadatarY   versionrI   ra   descriptionr7   Nr8   r7   r@   rA   ro   ro      sQ    &"MN.-N!L&
I#*r@   ro   c                      \ rS rSrSrSrg)AssistantVersioni  z.Represents a specific version of an assistant.r7   N)r9   r:   r;   r<   r=   r?   r7   r@   rA   ry   ry     s    8r@   ry   c                  $    \ rS rSr% SrS\S'   Srg)	Assistanti  z3Represents an assistant with additional properties.r   rK   r7   Nr8   r7   r@   rA   r{   r{     s    =2r@   r{   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]
assistantsra   nextr7   Nr8   r7   r@   rA   r}   r}     s    :>
Kr@   r}   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   valuer4   idr7   Nr8   r7   r@   rA   r   r   #  s    ;J2GGr@   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)Threadi,  z!Represents a conversation thread.r4   rL   r   rJ   rK   rt   ru   ThreadStatusrM   r   zdict[str, list[Interrupt]]
interruptszNotRequired[dict[str, Any]]	extractedr7   Nr8   r7   r@   rA   r   r   ,  sJ    +N*/NIL***J**[r@   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)
ThreadTaskiA  z"Represents a task within a thread.r4   r   rI   ra   r   list[Interrupt]r   Checkpoint | None
checkpointzThreadState | Nonestaterc   resultr7   Nr8   r7   r@   rA   r   r   A  s-    ,G
I!!!!r@   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)ThreadStateiM  z!Represents the state of a thread.zlist[dict] | dict[str, Any]r   zSequence[str]r   r^   r   rt   ru   ra   rJ   r   parent_checkpointzSequence[ThreadTask]r    r   r   r7   Nr8   r7   r@   rA   r   r   M  sN    +''
#N!%((ST6r@   r   c                  $    \ rS rSr% SrS\S'   Srg)ThreadUpdateStateResponseic  z7Represents the response from updating a thread's state.r^   r   r7   Nr8   r7   r@   rA   r   r   c  s    A)r@   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)Runij  z"Represents a single execution run.r4   run_idrL   rG   r   rJ   rK   	RunStatusrM   rt   ru   MultitaskStrategymultitask_strategyr7   Nr8   r7   r@   rA   r   r   j  sJ    ,KN3',kN))@r@   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rg)Croni  zRepresents a scheduled task.r4   rO   rG   ra   rL   zOnCompletionBehavior | Noneon_run_completedzdatetime | NonerQ   scheduletimezoner   rJ   rK   dictpayloaduser_idrP   ru   boolenabledr7   Nr8   r7   r@   rA   r   r     s~    &L"11b0M+s(-M6"""(N#M&r@   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\S'   Srg) 
CronUpdatei  z9Payload for updating a cron job. All fields are optional.r4   r   r   r   rQ   Inputinputr[   ru   rU   rq   rr   rs   webhookzAll | list[str]interrupt_beforeinterrupt_afterOnCompletionBehaviorr   r   r   zStreamMode | list[StreamMode]stream_modestream_subgraphsstream_resumable
Durability
durabilityr7   Nr8   r7   r@   rA   r   r     s    CM3MH0L!2N.0L;%%B$$A**=M)..$2SRr@   r   )
rG   rH   rI   rw   rq   rs   rJ   rK   ru   rv   )	rL   rJ   rK   ru   rq   rs   rM   r   r   )	r   rL   rG   rJ   rK   rM   ru   kwargsr   )rO   rG   rL   rQ   r   r   rJ   rK   r   r   rP   ru   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.ra   rL   r4   rG   rh   r   ru   zConfig | Nonerq   zContext | Noners   rb   zlist[str] | Noner   r   r   zMultitaskStrategy | Noner   r7   Nr8   r7   r@   rA   r   r   
  sh    AU>)8,(8&&;%%:E00Cr@   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.
rW   	namespacer4   keyr[   r   r   rJ   rK   r7   Nr8   r7   r@   rA   r   r   %  s9    
 X	H D27r@   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]]
namespacesr7   Nr8   r7   r@   rA   r   r   :  s    4Jr@   r   c                  $    \ rS rSr% SrS\S'   Srg)
SearchItemiA  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scorer7   Nr8   r7   r@   rA   r   r   A  s     r@   r   c                  $    \ rS rSr% SrS\S'   Srg)SearchItemsResponseiL  z'Response structure for searching items.zlist[SearchItem]itemsr7   Nr8   r7   r@   rA   r   r   L  s    17r@   r   c                  @    \ rS rSr% SrS\S'    S\S'    SrS\S	'   S
rg)
StreamPartiS  z'Represents a part of a stream response.r4   eventr   dataNra   r   r7   )r9   r:   r;   r<   r=   r>   r   r?   r7   r@   rA   r   r   S  s"    1J1
J5B
r@   r   )v1v2c                  H    \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'   S
rg)TaskPayloadii  zPayload for a task start event.r4   r   rI   r   r   rW   triggersr7   Nr8   r7   r@   rA   r   r   i  s&    )G*
I*J(Vr@   r   c                  T    \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S
\S'   Srg)TaskResultPayloadiv  z Payload for a task result event.r4   r   rI   ra   r   list[dict[str, Any]]r   r[   r   r7   Nr8   r7   r@   rA   r   r   v  s0    *G*
I-=$$AFr@   r   c                  `    \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S
\S'    S\S'   Srg)CheckpointTaskPayloadi  zA 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`
r4   r   rI   zNotRequired[str]r   zNotRequired[Any]r   z!NotRequired[list[dict[str, Any]]]r   rc   r   r7   Nr8   r7   r@   rA   r   r     s=     	G*
I*9N11V  Cr@   r   c                  `    \ rS rSr% SrS\S'    S\S'    S\S'    S\S	'    S\S
'    S\S'   Srg)CheckpointPayloadi  zPayload for a checkpoint event.rc   rq   r[   ru   r   rW   r   parent_configzlist[CheckpointTaskPayload]r    r7   Nr8   r7   r@   rA   r   r     s:    )!![V>
O7((\&&8r@   r   c                  D    \ rS rSr% S\S'    S\S'    S\S'    S\S	'   S
rg)_DebugCheckpointPayloadi  rY   stepr4   	timestampzLiteral['checkpoint']typer   r   r7   Nr9   r:   r;   r<   r>   r?   r7   r@   rA   r   r     s$    
I1N9
:!r@   r   c                  D    \ rS rSr% S\S'    S\S'    S\S'    S\S	'   S
rg)_DebugTaskPayloadi  rY   r   r4   r   zLiteral['task']r   r   r   r7   Nr   r7   r@   rA   r   r     s$    
I1N9
4!r@   r   c                  D    \ rS rSr% S\S'    S\S'    S\S'    S\S	'   S
rg)_DebugTaskResultPayloadi  rY   r   r4   r   zLiteral['task_result']r   r   r   r7   Nr   r7   r@   rA   r   r     s$    
I1N9
  ;"r@   r   c                  $    \ rS rSr% SrS\S'   Srg)RunMetadataPayloadi  z)Payload for the `metadata` control event.r4   r   r7   Nr8   r7   r@   rA   r   r     s    3K+r@   r   c                  H    \ rS rSr% SrS\S'    S\S'    S\S'    S	\S
'   Srg)ValuesStreamParti  z/Stream part emitted for `stream_mode="values"`.zLiteral['values']r   rW   nsr[   r   r   r   r7   Nr8   r7   r@   rA   r   r     s(    9
)ME
+$$<r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)UpdatesStreamParti  z0Stream part emitted for `stream_mode="updates"`.zLiteral['updates']r   rW   r   r[   r   r7   Nr8   r7   r@   rA   r   r     s    :
)ME
1r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)MessagesPartialStreamParti  zDStream part emitted for partial message chunks (`messages/partial`).zLiteral['messages/partial']r   rW   r   r   r   r7   Nr8   r7   r@   rA   r   r     s    N
%%)ME
.r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)MessagesCompleteStreamParti   z@Stream part emitted for complete messages (`messages/complete`).zLiteral['messages/complete']r   rW   r   r   r   r7   Nr8   r7   r@   rA   r   r      s    J
&&)ME
)r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)MessagesMetadataStreamParti  z?Stream part emitted for message metadata (`messages/metadata`).zLiteral['messages/metadata']r   rW   r   r[   r   r7   Nr8   r7   r@   rA   r   r     s    I
&&)ME
Rr@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)MessagesTupleStreamParti  zMStream part emitted for `stream_mode="messages"` (raw message+metadata pair).zLiteral['messages']r   rW   r   r   r   r7   Nr8   r7   r@   rA   r   r     s    W
)ME
>r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)CustomStreamParti!  z/Stream part emitted for `stream_mode="custom"`.zLiteral['custom']r   rW   r   r   r   r7   Nr8   r7   r@   rA   r   r   !  s    9
)ME
ICr@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)CheckpointsStreamParti,  z4Stream part emitted for `stream_mode="checkpoints"`.zLiteral['checkpoints']r   rW   r   r   r   r7   Nr8   r7   r@   rA   r   r   ,  s    >
  )ME
!r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)TasksStreamParti7  z.Stream part emitted for `stream_mode="tasks"`.zLiteral['tasks']r   rW   r   zTaskPayload | TaskResultPayloadr   r7   Nr8   r7   r@   rA   r   r   7  s    8
)ME
)),r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)DebugStreamPartiB  z.Stream part emitted for `stream_mode="debug"`.zLiteral['debug']r   rW   r   DebugPayloadr   r7   Nr8   r7   r@   rA   r   r   B  s    8
)ME
"r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)MetadataStreamPartiM  z3Control event with `run_id` and other run metadata.zLiteral['metadata']r   rW   r   r   r   r7   Nr8   r7   r@   rA   r   r   M  s    =
)M0
#r@   r   c                  0    \ rS rSr% SrS\S'    S\S'   Srg)	Sendik  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.
r4   noderc   r   r7   Nr8   r7   r@   rA   r   r   k  s     I=  7r@   r   c                  <    \ rS rSr% SrS\S'    S\S'    S\S'   S	rg
)Commandiz  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   resumer7   Nr8   r7   r@   rA   r   r   z  s-     ,+ 76
 Kr@   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.r4   r   ra   rL   r7   Nr8   r7   r@   rA   r  r    s    .Kr@   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__r7   Nr8   r7   r@   rA   r  r    s    - 0///r@   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  r7   Nr8   r7   r@   rA   r  r    s    1 &%%%r@   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__r7   Nr8   r7   r@   rA   r	  r	    s    
 :9r@   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 )Nr7   )selfr   s     rA   
model_dump_BaseModelLike.model_dump  s     r@   r7   N)r   r   returnr[   )r9   r:   r;   r<   r=   r>   r  r?   r7   r@   rA   r  r    s(    L**++ 
r@   r  r   	_JSONLike_JSONMapr   rr   )nr=   
__future__r   collections.abcr   r   dataclassesr   r   typingr   r	   r
   r   r   r   r   typing_extensionsr   r   r   r4   rt   r   r   ThreadStreamMode
StreamModeDisconnectModer   OnConflictBehaviorr   r   r2   AllIfNotExistsPruneStrategyCancelActionBulkCancelRunsStatusAssistantSortByThreadSortBy
CronSortBy	SortOrderrU   r^   rf   	Subgraphsro   ry   r{   r}   r   r   r   r   r   r   r   r   AssistantSelectFieldThreadSelectFieldRunSelectFieldCronSelectFieldrY   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   rr   r7   r@   rA   <module>r5     s   9 " -     5CH~ jVW	 => CD  


 -. HI  23  /0  ,-
@Hy H cl .() /0 ./ :;  B I 
 M"	
Ye .
C 
C=) =, k!"	+I +.	} 	3 3Ly LH	 H\Y \*	" 	"7) 7,*	 *A) A*'9 'B"S% "SP 	  
  
 $ c	E!D(4/ C-!8889
5m#$%&E#}$%s*+, 

 	 D	 D689 8*KI KU 8) 8  
#
W) 
WG	 GDI D09	 9""i ""	 "#i # ')::=TT ?, ,
=y 
=2	 2/	 /* *S S?i ?Dy D"I "-i -#i #$ $   !! !	!
     	 
 79 7iu 6 	  0x 0&x &:X :	X 	 czC'%/$6	9 6y$y/:tJ7GG	HH) 
 ''.8>IHT y   r@   