ó
    ýÞ jÇp  ã                  ó
  • % 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      rh\\>-  \?-  \@-  S-  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)ÚLangSmithTracingéo   z$Configuration for LangSmith tracing.ÚstrÚproject_nameÚ
example_id© N©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú__annotations__Ú__static_attributes__r7   ó    ÚN/var/www/html/gaurav/venv/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  zÖ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Ú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…  zù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`
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  zÎ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.
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±  z™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__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ð ˆc�l€Ø .àÐ(Ñ)€ðð Ð/Ñ0€ðð Ð.Ñ/€ðð Ð:Ñ;Ð ðð ØBñ€ðð ØIñ€ðð ðñ€
ðð �MÑ"€	ðô
ˆY˜eò ô.
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8ˆ9ô 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ô #ô$˜ô $ð Øñàñ ð !ñ!ð !ñ	!ð
 ñð ñð ñð ñð ñ	ð ñ
ð ðô7ˆ9ô 7ôˆi˜uò ô6 ˜	ô  ô0�xô 0ô&�xô &ô:�Xô :ô	�Xô 	ð ˜S‘y 5Ñ(¨4Ñ/°$Ñ6€	ˆ9Ó 6ØØˆˆy˜$˜y™/¨:°t¸JÑ7GÐGÑ	HÐHñ€ˆ)ó ð
 Ð'Ñ'¨.Ñ8¸>ÑIÈHÑTð €yó ð €ˆÔ r@   