ޠj SrSSKJr SSKrSSKJr SSKJrJr SSKJ r J r S Sjr SSjr SS jr SS jrSS jrSS jrg)u@Small pure helpers for the Pipecat → LangSmith span processor.) annotationsN)datetime)AnyOptional)build_assistant_messagetry_parse_json_objectc[R"U5n[ U[ 5(d/$UVs/sHn[ U[ 5(dMUPM sn$![R[4a /s$f=fs snf)zHParse a Pipecat ``llm`` span's ``input`` (a JSON message list) to dicts.)jsonloadsJSONDecodeError TypeError isinstancelistdict) input_datarawms a/var/www/html/gaurav/venv/lib/python3.13/site-packages/langsmith/integrations/pipecat/_helpers.pyparse_llm_messagesrsljj$ c4   2s!jD1As 22  ) ,  3sAA:A:A76A7cR[U[[45(a [U5$S$)zHCoerce a numeric span-attribute value to ``int``, or ``None`` otherwise.N)rintfloat)values r_as_intrs!#EC<883u:BdBcx0n[URS55=nbX!S'[URS55=nbX!S'0n[URS55=nbX#S'[URS55=nbX#S'U(aX1S '[URS 55=nbS U0US 'U$) zFRead Pipecat's ``gen_ai.usage.*`` span keys into ``set_usage`` kwargs.zgen_ai.usage.input_tokens input_tokenszgen_ai.usage.output_tokens output_tokensz$gen_ai.usage.cache_read.input_tokens cache_readz(gen_ai.usage.cache_creation.input_tokenscache_creationinput_token_detailszgen_ai.usage.reasoning_tokens reasoningoutput_token_details)rget) attributesusagev input_details rextract_llm_usager)sE Z^^$?@ AAN !n Z^^$@A BBO!"o#%L Z^^$JK LL &'\" Z^^$NO PP *+%&'3#$ Z^^$CD EER)4a(8$% Lrc[U5n[U[5(aURS5(aSS0UE$[U[5(aUO [ U5n[ U5$)zBuild the assistant completion for a Pipecat ``llm`` span. A structured response carrying ``tool_calls`` is forwarded in its OpenAI shape; anything else becomes plain assistant text. tool_callsrole assistant)rrrr$strr) output_dataparsedcontents rbuild_completion_messager26s\ #; /F&$FJJ|$<$< .v..' S99ks;?OG "7 ++rc[[R"U5R5S-5$![[ 4a gf=f)zDParse an ISO 8601 timestamp to epoch nanoseconds (0 if unparseable).geAr)rr fromisoformat timestamp ValueErrorr )r5s r iso_to_nsr7CsB8)))4>>@3FGG  "s/2AAcURS5nU(aS[SU554$URS5S:XaS[URS554$g) zDedup identity for a tool-round-trip message, or ``None`` otherwise. Only assistant tool-call messages and tool-result messages carry one; user turns and plain assistant replies (owned by other sources) return ``None`` so they are ignored here. r+assistant_tool_callc3T# UHn[URS55v M! g7f)idN)r.r$).0cs r #tool_message_key..Ts ,Rz!St-=-=zs&(r,tool tool_result tool_call_idN)r$tupler.)messager+s rtool_message_keyrEKsX\*J%u,Rz,R'RSS{{6f$s7;;~#>?@@ r)rrreturnzlist[dict[str, Any]])rrrFr)r%dict[str, Any]rFrG)r/rrFrG)r5r.rFr)rDrGrFzOptional[tuple])__doc__ __future__rr rtypingrr"langsmith._internal.voice._helpersrrrrr)r2r7rErrrMs8F"   3C . , r