xj PUddlmZddlmZddlZddlmZddlmZddl m Z ddl m Z m Z mZer ddlmZmZmZed g Zd ed <d&dddeddfdZd'dZd(dZdefdZdefdZdefdZdefdZ d)dZd*dZ d+d!Z d)d"Zd&d#dd$eddfd%Z dS),) ContextVar) TYPE_CHECKINGN)SPANDATA)should_send_default_pii) StreamedSpan)event_from_exceptionhas_data_collection_enabledsafe_serialize)AnyOptionalUnionpydantic_ai_agent_context_stack)defaultz ContextVar[list[dict[str, Any]]]_agent_context_stackFagentr is_streamingreturnct}|||dt|dS)zCPush an agent context onto the stack along with its streaming flag.)rrN)rgetcopyappendset)rrstacks ZC:\Projects\Historical\venv\Lib\site-packages\sentry_sdk/integrations/pydantic_ai/utils.py push_agentrsS $ $ & & + + - -E LL5,??@@@U#####ct}|r|t|dS)z$Pop an agent context from the stack.N)rrrpoprrs r pop_agentr sN $ $ & & + + - -E  U#####rcXt}|r|ddSdS)z0Get the current agent from the contextvar stack.rNrrrs rget_current_agentr$(s/ $ $ & &E "Ry!! 4rctt}|r|dddSdS)z1Get the streaming flag from the contextvar stack.r"rFr#rs rget_is_streamingr&0s8 $ $ & &E 4Ry}}^U333 5rctsdSddlm}tj|}|dSt |ddS)z Check if prompts should be sent to Sentry based on the deprecated ``send_default_pii`` option and the ``include_prompts`` integration setting. TODO: Remove this once `send_default_pii` is deprecated. F)PydanticAIIntegrationNinclude_prompts)rr) sentry_sdk get_clientget_integrationgetattr)r) integrations r_should_send_prompts_legacyr18sf # $ $u'''''''))99:OPPKu ; 15 9 99rctj}t|jr&t |jdddSt S)Ndata_collectiongen_aiinputsr,r-r optionsboolr1clients r_should_send_inputsr;MsO  " $ $F"6>22KFN#45h?IJJJ & ( ((rctj}t|jr&t |jdddSt S)Nr3r4outputsr6r9s r_should_send_outputsr>UsO  " $ $F"6>22LFN#45h? JKKK & ( ((rspan,Union[sentry_sdk.tracing.Span, StreamedSpan]c*|}|st}|rzt|drl|jrgt|tr'|t j|jdS|t j|jdSdSdSdS)zSet agent-related data on a span. Args: span: The span to set data on agent: Agent object (can be None, will try to get from contextvar if not provided) nameN) r$hasattrrB isinstancer set_attributerGEN_AI_AGENT_NAMEset_data)r?r agent_objs r_set_agent_datarI]sI (%'' FWY//FINF dL ) ) F   x99> J J J J J MM(4in E E E E E FFFFFFr model_obj Optional[str]c |sdSt|dr|jSt|dr4 |S#t$rt |cYSwxYwt |tr|St |S)zExtract model name from a model object. Args: model_obj: Model object to extract name from Returns: Model name string or None if not found N model_namerB)rCrMrB ExceptionstrrD)rJs r_get_model_namerPss ty,'' ## F # # ">>## # " " "y>> ! ! ! " Is # #9~~sAAAmodelmodel_settingsc8t}|}|s|rt|dr|j}t|tr|jn|j}|rRt|dr|tj|j t|}|r|tj ||}|s|rt|dr|j }|rtj tjtjtjtjd}t|t$r?|D](\} } || } | || | )dS|D]5\} } t|| rt+|| } | || | 4dSdS)aSet model-related data on a span. Args: span: The span to set data on model: Model object (can be None, will try to get from agent if not provided) model_settings: Model settings (can be None, will try to get from agent if not provided) rQsystemrR) max_tokens temperaturetop_pfrequency_penaltypresence_penaltyN)r$rCrQrDrrErGr GEN_AI_SYSTEMrTrPGEN_AI_REQUEST_MODELrRGEN_AI_REQUEST_MAX_TOKENSGEN_AI_REQUEST_TEMPERATUREGEN_AI_REQUEST_TOP_P GEN_AI_REQUEST_FREQUENCY_PENALTYGEN_AI_REQUEST_PRESENCE_PENALTYdictitemsrr/) r?rQrRrHrJ set_on_spanrMsettings settings_map setting_name spandata_keyvalues r_set_model_dataris"##II $$wy''B'B$O )|<<O$-C 9h ' ' B K. 0@ A A A%Y//  C K5z B B BH , ,gi9I&J&J,+9"<#>2!)!J ( H    h % % 9.:.@.@.B.B 5 5* l \22$K e444 5 5 /;.@.@.B.B 9 9* l8\229#Hl;;E(# L%888+99" 9 9rc|rt|dsdStjj}t |r|dddsdS g}t|jdr|jjD]k\}}d|i}t|dr=|j}t|d dr |j |d <t|d dr |j |d <| |l|rst|tr/|t jt%|dS|t jt%|dSdS#t($rYdSwxYw) zSet available tools data on a span from an agent's function toolset. Args: span: The span to set data on agent: Agent object with _function_toolset attribute _function_toolsetNr3r4r5toolsrBfunction_schema description json_schema parameters)rCr,r-r7r rkrlrbrmr/rnrorrDrrErGEN_AI_REQUEST_AVAILABLE_TOOLSr rGrN)r?rclient_optionsrl tool_nametool tool_infoschemas r_set_available_toolsrws ':;;*,,4N">22/0:8D  F  5*G 4 4 (#(#:#@#F#F#H#H ( ( 4#Y/ 4!233E!1Fv}d;;F393E -0v}d;;E282D ,/ Y''''  $ -- "";^E=R=R ;^E=R=R         sC%E+:-E++ E98E9exchandledct|tjjd|d\}}tj||dS)N pydantic_ai)typery)rr mechanism)hint)rr,r-r7 capture_event)rxryeventr~s r_capture_exceptionrsU& !,..6(W==KE4 U......r)F)rN)rr )r?r@rr rN)rJr rrK)r?r@rQr rRr rN)! contextvarsrtypingrr,sentry_sdk.constsrsentry_sdk.scopersentry_sdk.tracesrsentry_sdk.utilsrr r r r r r__annotations__r8rr r$r&r1r;r>rIrPrirwrrrrs""""""" &&&&&&444444****** ,++++++++++