"j' ,%SSKJr SSKJr SSKJrJr SSKJrJ r SSK J r J r J r JrJrJrJr SSKJrJrJr SSKJrJr SSKJr SS KJrJr SS KJr S S K J!r!J"r"J#r# \"S 5r$\"S5r%\"S5r&\"S5r'\"SSS9r(\"SSS9r)\ Sr*S\+S'\ "SS9"SS55r,\ "SS9"SS55r-\ "SS9"SS55r.\ "SS9"S S!55r/\ "SS9"S"S#55r0\ "SS9"S$S%55r1\ "SSS&9"S'S(55r2\ "SS9"S)S*55r3\ "SS9"S+S,55r4\ "SS9"S-S.55r5\ "SS9"S/S055r6\ "SS9"S1S255r7\ "SS9"S3S455r8\ "SS9"S5S655r9\ "SS9"S7S855r:\ "SS9"S9S:55r;\,\0-\.-\4-\2-\5-\7-\8-\9-rS?\ \(\5r>"S@SA\ \&\5r?\ SBr@S\+SC'"SDSE\ \)\5rASPSFjrB\ "SSS&9"SGSH\ \$\%\&455rC"SISJ\=\$\$4\ \$5rD"SKSL\>\$\ \$5rE"SMSN\?\&\ \&5rFgO)Q) annotations)abstractmethod) AwaitableCallable)KW_ONLY dataclass)AnyGenericLiteralProtocol TypeAliasTypeVarcast)AgentStreamEvent ModelMessage ModelResponse)ModelRequestContextModelRequestParameters) ModelSettings) RunContextToolDefinition) ToolsetTool)IDENTITY_CODEC JSON_CODECDurabilityCodecParamsTWireTResultTConfigTParamsT_contraT) contravariant ConfigT_co) covariant)functionmcpdynamicr ToolsetKind)frozencJ\rSrSr%SrSrS\S'S\S'SrS \S 'S \S 'S rg)ModelRequestIdzIdentifies a model request operation in an engine's configuration resolver. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). N str | Nonemodel_idr_Fbool streamingstr model_name) __name__ __module__ __qualname____firstlineno____doc__r.__annotations__r1__static_attributes__r4`/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_ai/durable_exec/_operation.pyr+r+s'  HjJItOr<r+cV\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S'Srg)ModelRequestParams,Nr-r.rr/zlist[ModelMessage]messageszModelSettings | Nonemodel_settingsrmodel_request_parametersRunContext[Any] run_contextr4r5r6r7r8r.r:r;r4r<r=r?r?,s)HjJ  ((44  r<r?c<\rSrSr%SrSrS\S'S\S'S\S 'S rg) ModelCancelSuspendedResponseId6zIdentifies cancellation of a suspended model response for engine configuration. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). Nr-r.rr/r2r3r4r5r6r7r8r9r.r:r;r4r<r=rHrH6  HjJOr<rHcB\rSrSr%SrS\S'S\S'S\S'S \S 'S rg) "ModelCancelSuspendedResponseParamsBNr-r.rr/rresponsezRunContext[Any] | NonerEr4rFr4r<r=rMrMBsHjJ''r<rMc<\rSrSr%SrSrS\S'S\S'S\S 'S rg) ModelCompactMessagesIdJzIdentifies a durable message-compaction operation for engine configuration. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). Nr-r.rr/r2r3r4rJr4r<r=rQrQJrKr<rQcL\rSrSr%SrS\S'S\S'S\S'S\S 'S \S 'S rg) ModelCompactMessagesParamsVNr-r.rr/rrequest_context instructionsrDrEr4rFr4r<r=rTrTVs#HjJ((  r<rT)r)kw_onlyc\rSrSrSrSrg)EventStreamHandlerId_zIdentifies a durable event-stream handler invocation for engine configuration. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). r4N)r5r6r7r8r9r;r4r<r=rZrZ_s   r<rZc4\rSrSr%S\S'S\S'S\S'Srg ) EventStreamHandlerParamsireventrr/rDrEr4Nr5r6r7r8r:r;r4r<r=r]r]is J  r<r]c8\rSrSr%SrS\S'S\S'S\S'Srg ) CapabilityOperationIdpa Identifies an operation contributed by a capability. Engine configuration receives these operations through the same backend as built-in model and tool operations. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). r2 capability_idrr/ operationr4Nr5r6r7r8r9r:r;r4r<r=rbrbpsJNr<rbc8\rSrSr%SrS\S'S\S'S\S'S rg ) ToolsetGetToolsId~zIdentifies durable tool discovery for a particular toolset. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). r( toolset_kindrr/r2 toolset_idr4Nrfr4r<r=rhrh~ JOr<rhc*\rSrSr%S\S'S\S'Srg)ToolsetGetToolsParamsrDctxrr/r4Nr`r4r<r=rnrns Jr<rnc.\rSrSr%SrS\S'S\S'Srg) ToolsetGetInstructionsIdzIdentifies durable instruction discovery for an MCP toolset. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). r2rkrr/r4Nrfr4r<r=rrrrs OJr<rrc8\rSrSr%SrS\S'S\S'S\S'S rg ) ToolsetValidateToolArgumentsIdzIdentifies durable argument validation for a particular toolset. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). r(rjrr/r2rkr4Nrfr4r<r=rururlr<ruc8\rSrSr%SrS\S'S\S'S\S'S rg ) ToolsetCallToolIdzIdentifies durable tool execution for a particular toolset. See the [durable backend guide](https://pydantic.dev/docs/ai/capabilities/durable_execution/backends/). r(rjrr/r2rkr4Nrfr4r<r=rxrxrlr<rxcH\rSrSr%S\S'S\S'S\S'S\S 'S \S 'S rg )ToolsetCallToolParamsr2namerr/dict[str, Any] tool_argsrDrpzToolsetTool[Any] | Nonetoolr4Nr`r4r<r=r{r{s IJ  !!r<r{cL\rSrSr%S\S'S\S'S\S'S\S 'S rS \S 'S rg )DynamicToolsetCallToolParamsr2r}rr/r~rrDrpNzToolDefinition | Nonetool_defr4)r5r6r7r8r:rr;r4r<r=rrs# IJ &*H#*r<rDurableOperationIdc@\rSrSrSr\SSj5r\SSj5rSrg) ParameterTransportaSerialize operation parameters for an engine boundary and rebuild them worker-side. The `runtime` passed to `load` is engine-side context needed while rebuilding parameters. For example, Temporal passes its durability capability so serialized run contexts can be restored. cgNr4selfparamss r=dumpParameterTransport.dump.1r<cgrr4rpayloadruntimes r=loadParameterTransport.loadsCFr<r4N)rrreturnr)rrrobjectrr r5r6r7r8r9rrrr;r4r<r=rrs% 11FFr<rc,\rSrSrSr\SSj5rSrg) CacheIdentityzKProject semantic parameters into opaque hash inputs for hash-keyed engines.cgrr4rs r=projectCacheIdentity.projectsEHr<r4N)rr!rztuple[object, ...])r5r6r7r8r9rrr;r4r<r=rrsUHHr<rc@\rSrSrSr\SSj5r\SSj5rSrg) ResultCodecz@Encode and decode an operation result across an engine boundary.cgrr4rvalues r=rResultCodec.dumprr<cgrr4rrs r=rResultCodec.loads03r<r4Nrrrrrrrrrr4r<r=rrs!J1133r<r)modelr_r capabilityOperationConfigRolecP\rSrSr\SSj5r\SSj5rSrg)DurableOperationConfigcgrr4)rrole operation_ids r=baseDurableOperationConfig.basesber<cgrr4)rrrr tool_names r=for_toolDurableOperationConfig.for_tools'*r<r4N)rrrrrr#) rrrrr object | Nonerr2rzConfigT_co | Literal[False])r5r6r7r8rrrr;r4r<r=rrsRee*!*) *  *  * %**r<rcNURURURUUS9$)zFResolve tool configuration shared by callable and registered backends.)rrr)r config_roler)configrerrs r=resolve_tool_operation_configr s2 ??++   r<cd\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S'SrS\S'Srg)DurableOperationiaA complete semantic declaration that an engine backend can bind. Attributes: operation_id: Stable typed identity used for naming and configuration. handler: Semantic async operation body. parameter_transport: Codec between semantic parameters and engine wire parameters. cache_identity: Projection consulted by hash-keyed engines. result_codec: Codec for the handler result. config_role: Coarse configuration category for the operation. invocation_label: Optional per-call display or naming label. rrz'Callable[[ParamsT], Awaitable[ResultT]]handlerz"ParameterTransport[ParamsT, WireT]parameter_transportzCacheIdentity[ParamsT]cache_identityzResultCodec[ResultT] result_codecrrNzCallable[[ParamsT], str] | Noneinvocation_labelr4)r5r6r7r8r9r:rr;r4r<r=rrs9 %$ 44;;**&&$$8<5\rSrSrSrSS.S SjjrS SjrS SjrSrg ) TypedResultCodeciAzAEncode and validate results using a declared runtime result type.json)modecJXlUS:Xa [Ulg[Ulg)Nr) _result_typerr_codec)r result_typers r=__init__TypedResultCodec.__init__Ds'59V^z  r<cNURRURU5$r)rrrrs r=rTypedResultCodec.dumpHs{{ 1 1599r<cj[[URRURU55$r)rrrrrrs r=rTypedResultCodec.loadKs&GT[[--d.?.?IJJr<)rrN)rrrzLiteral['json', 'identity']rNonerr) r5r6r7r8r9rrrr;r4r<r=rrAsKSYX:Kr<rN) rzDurableOperationConfig[ConfigT]rez)DurableOperation[ParamsT, WireT, ResultT]rrrr2rzConfigT | Literal[False])G __future__rabcrcollections.abcrr dataclassesrrtypingr r r r r rrpydantic_ai.messagesrrrpydantic_ai.modelsrrpydantic_ai.settingsrpydantic_ai.toolsrrpydantic_ai.toolsets.abstractrrrrrrrrr r!r#r(r:r+r?rHrMrQrTrZr]rbrhrnrrrurxr{rrrrrrrrrrrrr4r<r=rs"/*LLLNNJ.85?? )  )  ) )> \T 2  !=> Y> $    $!!! $ $((( $ $!!! $%  &  $!!!  $    $ $  $ $ $ $""" $+++$%     %%I  G%0( GIGN+XI4''"H4"))O!PYPa *WZ0( *  + 8         $%=www67=&=,!3GW4D!EwwGWmG,gg.> K{7+WW-= Kr<