"j"&%SrSSKJr SSKrSSKJrJr SSKJrJ r SSK J r J r J r Jr SSKJr SS KJr SS KJrJrJrJrJrJrJrJrJrJrJr \ (aSS KJr \ S r S \!S'Sr"S \!S'SSjr#\"SS55r$"SS\%\$5r&g)zInternal helpers for the `RunContext.enqueue` / `AgentRun.enqueue` APIs. These types live here (rather than in `messages.py`) because they're internal runtime state for the pending message queue, not part of the wire-serializable message history. ) annotationsN)IterableSequence) dataclassfield) TYPE_CHECKINGLiteral SupportsIndex TypeAlias)uuid7) UserError) ModelMessage ModelRequestModelRequestPart ModelResponseRetryPromptPart SpeechPartSystemPromptPartToolAvailabilityDeltaPartToolReturnPartToolSearchReturnPartUserPromptPart) UserContent)asap when_idler PendingMessagePriorityz-UserContent | ModelRequestPart | ModelMessageEnqueueContentc ^^^^/m/m/mSUU4SjjmSUUU4SjjnUHn[U[[45(aU"5 TRU5 M8[U[[ [ [[[[45(aT"5 TRU5 MTRU5 M U"5 T$)aRAssemble enqueue items into a list of [`ModelMessage`][pydantic_ai.messages.ModelMessage]s. Adjacent [`UserContent`][pydantic_ai.messages.UserContent] items are gathered into one [`UserPromptPart`][pydantic_ai.messages.UserPromptPart], and part-style items (user content and [`ModelRequestPart`][pydantic_ai.messages.ModelRequestPart]s) are coalesced into a single [`ModelRequest`][pydantic_ai.messages.ModelRequest]; complete `ModelMessage`s are emitted as-is. Order is preserved, so a `ModelResponse` followed by part-style items produces the response then a request built from those parts. c>T(a`[T5S:Xa[TS[5(aTSO [T5nTR [ US95 TR 5 gg)Nr r)content)len isinstancestrlistappendrclear)singler!partss Q/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_ai/_enqueue.py flush_content._build_enqueue_messages..flush_contentTsU $'w<1#4GAJPS9T9TWQZZ^_fZgF LL7 8 MMO c>T"5 T(a2TR[[T5S95 TR5 gg)N)r))r&rr%r')r+messagesr)sr* flush_request._build_enqueue_messages..flush_request\s.  OOLtE{; < KKM r-returnNone) r#rrr&rrrrrrr)itemsr0itemr!r+r/r)s @@@@r*_build_enqueue_messagesr7Fs$&H$&E!#G  d\=9 : : O OOD !   $)     O LL  NN4 '(O Or-cl\rSrSr%SrS\S'SrS\S'\"SS 9rS \S '\ SS .SS jj5r Sr g)PendingMessagezapOne or more [`ModelMessage`][pydantic_ai.messages.ModelMessage]s queued for injection into the agent conversation. Enqueued via [`RunContext.enqueue`][pydantic_ai.tools.RunContext.enqueue] or [`AgentRun.enqueue`][pydantic_ai.run.AgentRun.enqueue] and automatically drained at the appropriate time during the agent run by the internal `PendingMessageDrainCapability`. list[ModelMessage]r/rrpriorityc([[55$N)r$r r-r*PendingMessage.s CLr-)default_factoryr$ enqueue_idr<cz[U5nU(dg[US[5(d [S5eU"X1S9$)uBuild a `PendingMessage` from `enqueue` arguments, or `None` when there's nothing to send. Returns `None` for an empty call (enqueueing nothing is a no-op rather than an error). Raises: UserError: If the assembled messages don't end in a [`ModelRequest`][pydantic_ai.messages.ModelRequest] — e.g. a lone `ModelResponse` — since the agent needs a request to respond to. NzEnqueued content must end with a `ModelRequest` (or user content / `ModelRequestPart` items that form one), so the agent has a request to respond to.)r/r<)r7r#rr)clsr<r!r/s r* from_contentPendingMessage.from_contentsE+73(2, 55R H88r-r?N)r!rr<rr3zPendingMessage | None) __name__ __module__ __qualname____firstlineno____doc____annotations__r<rrC classmethodrH__static_attributes__r?r-r*r9r9zsU! <(.H$-,@AJAYW]99r-r9cv^\rSrSrSrS S U4SjjjrS SjrSU4SjjrSSjrSSjr SSjr SS jr S r U=r $)PendingMessageQueuezFA run's pending messages with thread-safe append and drain operations.cf>[TU]U5 SUl[R"5Ulg)NF)super__init___closed threadingLock_lock)selfr/ __class__s r*rWPendingMessageQueue.__init__s% " ^^% r-c&[[U544$r>)rSr%)r\protocols r* __reduce_ex__!PendingMessageQueue.__reduce_ex__s"T$ZM11r-c>UR UR(a [S5e[TU]U5 SSS5 g!,(df  g=f)Nz;`enqueue` is not available because the agent run has ended.)r[rXrrVr&)r\pendingr]s r*r&PendingMessageQueue.appends3 ZZ|| ]^^ GN7 #ZZs ,A AcrUR URU5sSSS5 $!,(df  g=fr>)r[ _pop_priority)r\r<s r* pop_priority PendingMessageQueue.pop_prioritys! ZZ%%h/ZZs( 6cUR URS5nURS5nU(dU(dSUlX4sSSS5 $!,(df  g=f)z:Drain both priorities, or atomically close an empty queue.rrTN)r[rgrX)r\rrs r* drain_at_end PendingMessageQueue.drain_at_endsD ZZ%%f-D**;7I # ? ZZs :A Ac^UR SUlSSS5 g!,(df  g=f)NT)r[rX)r\s r*closePendingMessageQueue.closes ZZDLZZs ,cUVs/sHo"RU:XdMUPM nnUVs/sHo"RU:wdMUPM snUSS&U$s snfs snfr>rD)r\r<rdselecteds r*rg!PendingMessageQueue._pop_prioritysR+/P43C3Cx3OG4P*.O$w2B2Bh2N7$OQQOsA A AA)rXr[)r?)r/zIterable[PendingMessage]r3r4)r`r r3z=tuple[type[PendingMessageQueue], tuple[list[PendingMessage]]])rdr9r3r4)r<rr3zlist[PendingMessage])r3z1tuple[list[PendingMessage], list[PendingMessage]]r2)rJrKrLrMrNrWrar&rhrkrnrgrQ __classcell__)r]s@r*rSrSs3P&& 2$ 0# r-rS)r5zSequence[EnqueueContent]r3r;)'rN __future__rrYcollections.abcrr dataclassesrrtypingrr r r _uuidr exceptionsrr/rrrrrrrrrrrrrrOrr7r9r%rSr?r-r*rzs #.(CC!    %%,,?$@ @L K.1h ,9,9 ,9^%$~.%r-